DJ Erraballi
Jenny
@task def create_parameter_payload(result, param): return {'blah': param, 'resultId': result}
params = create_parameter_payload.map(param=unmapped(param), result=a_results) flow_run_task.map(flow_name=unmapped('DownstreamFlow'), parameters=params)
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.