orquesta_with_items

---
version: 1.0

input:
  - dry_run
  - domains

tasks:
  sk_update_domains:
    with:
      items: <% ctx(domains) %>
      concurrency: 5
    action: i371.sk_update_domain 
    input:
      dry_run: <% ctx(dry_run) %>
      domain: <% item() %>
    next:
      - publish:
          domains_res: <% result() %>
        do: log_results
      - when: <% not(result().result) %>
        do: fail
  log_results:
    join: all
    action: i371.sk_log_results
    input:
      domains: <% ctx(domains_res) %>

Each item looks like this:

      {
        "dh_name": "some FQDN",
        "domain_name": "some string",
        "db_port": 3306,
        "ds_name": "some string",
        "dh_id": 12,
        "db_name": "db_name",
        "db_host": "dbadress",
        "domain_id": 1941
      }