damien michelle
03/01/2022, 3:05 PMKevin Kho
get_task_run_resultdamien michelle
03/01/2022, 3:19 PMKevin Kho
get_task_run_resultdamien michelle
03/01/2022, 3:46 PMKevin Kho
create_flow_run.map()Kevin Kho
@task
def get_params_list(codes):
    res = []
    for code in codes:
        res.append({"country_code":code}
    return res
with Flow(...) as flow:
    codes = Parameter("codes", [123, 456])
    params_list = get_params_list(codes)
    create_flow_run.map(flow_name=unmapped("name"), project_name=unmapped("name"), parameters=params_list)damien michelle
03/01/2022, 4:18 PM