Hello,
Can map_task take pd.DataFrame as input?
e....
# ask-the-communityf
Frank Shen
04/04/2023, 10:51 PMHello,
Can map_task take pd.DataFrame as input?
e.g.
Copy code
@task
def t1(data: pd.DataFrame):
...
@workflow
def wf():
partitioned_data = some List of pd.DataFrame
map_task(t1)(data=partitioned_data)k
Kevin Su
04/04/2023, 11:39 PMyes, map task can take any data type
150 Views