salmon-refrigerator-32115
@task def t1(data: pd.DataFrame): ... @workflow def wf(): partitioned_data = some List of pd.DataFrame map_task(t1)(data=partitioned_data)
glamorous-carpet-83516