loops.yml

operation:
  name: print
  inputs:
    - host
    - port
  action:
    python_script: |
      ...
  outputs:
    - op_result
    - status_code
  results:
    GOOD: host == 2
    BAD: host == 3
    SUCCESS

-----

flow:
  name: bopho
  inputs:
    - hosts: [1,2,3]
    - default_port: "'8080'"
  workflow:
    ...

-------------

print_hosts:
  loop:
    for: host in hosts
    delimiter: ","
  do:
    ops.print:
      - host
      - default_port
  publish:
    - agg_result: agg_result + op_result
    - agg_status: agg_status && (status_code == 1)
  break: status_code == o
  navigate:
    SUCCESS: the_next_step
    BREAK: calculate_error_step

---------------

print_hosts:
  loop:
    for: host in hosts
    #delimiter: ","
    #on_end: task3
      do:
        ops.print:
          - host
          - port: default_port
      publish:
        - agg_result: agg_result + op_result
        - agg_status: agg_status && (status_code == 1)
      navigate:
        GOOD: task4

task2:
  .........
task3:
  .........
task4:

------------

# simple example

flow:
  name: bopho
  inputs:
    - hosts: "'1,2,3'"
    - default_port: "'8080'"
  workflow:
    print_hosts:
      loop: 
        for: host in hosts
          do:
            ops.print:
              - host
              - port: default_port

    task2:
      .........

@avimora @meshipeer @meirwah
have a look