DJ Erraballi
@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])
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.