https://flyte.org logo
#ask-the-community
Title
# ask-the-community
f

Frank Shen

04/04/2023, 10:51 PM
Hello, 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 PM
yes, map task can take any data type