David Michael Carter
02/26/2022, 10:59 PMtask_run_name
would be a value based on a specific key for that mapped dict index. Anyone have experience naming tasks based on a mapped dictionary?Kevin Kho
02/26/2022, 10:59 PMDavid Michael Carter
02/26/2022, 11:01 PMKevin Kho
02/26/2022, 11:04 PMfrom prefect import Flow, task
@task
def mytask(x):
return x+1
with Flow("test") as flow:
mytask.map({"a": 1, "b": 2})
flow.run()
David Michael Carter
02/26/2022, 11:06 PMKevin Kho
02/26/2022, 11:08 PMDavid Michael Carter
02/26/2022, 11:11 PMtask_run_name="{myDict['name']}"
results in key error for ‘name’… trying various iterations on that ideaKevin Kho
02/26/2022, 11:12 PMfrom prefect import Flow, task
def generate_task_run_name(dict_val, **kwargs):
return "something" + str(dict_val['a'])
@task(task_run_name=generate_task_run_name)
def mytask(dict_val):
return dict_val["b"]+1
with Flow("test") as flow:
mytask.map([{"a": 1, "b": 2}, {"a": 3, "b": 4}])
flow.register("general_assembly")
David Michael Carter
02/26/2022, 11:20 PMKevin Kho
02/26/2022, 11:20 PMDavid Michael Carter
02/26/2022, 11:20 PM