DJ Erraballi
11/10/2020, 6:39 PM@task
def taskA() -> List[int]:
return results
with Flow() as flow:
param = Parameter('blah')
a_results = taskA()
flow_run_task = FlowRunTask()
flow_run_task.map(flow_name=unmapped('DownstreamFlow'), parameters=[{'blah': param, 'resultId': result} for result in a_results])