https://prefect.io logo
d

DJ Erraballi

11/10/2020, 6:49 PM
but i don’t think i can actually loop over a_results inline inthe flow definition right?
j

Jenny

11/10/2020, 7:06 PM
Hi @DJ Erraballi - I'm not sure of a solution off the top of my head but let me check this one for you.
Hi @DJ Erraballi - You'll need to add another task in here to handle your parameters. Something like this:
Copy code
@task
def create_parameter_payload(result, param):
    return {'blah': param, 'resultId': result}
Copy code
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.