DJ Erraballi
11/10/2020, 6:49 PMJenny
11/10/2020, 7:06 PM@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)
You may need a (unmapped) project name in there too.