Laura Lin
12/15/2022, 1:11 AMSamhita Alla
Laura Lin
12/15/2022, 4:19 PMKevin Su
12/15/2022, 6:49 PMLaura Lin
12/15/2022, 7:18 PMimport typing
import time
from flytekit import task, workflow, map_task
@task
def my_mappable_task(a: int) -> str:
time.sleep(a * 2)
return str(a)
@workflow
def my_wf(x: typing.List[int]) -> typing.List[str]:
return map_task(my_mappable_task)(
a=x
)
basic reproducible example modified from the map_task docsTyler Su
12/21/2022, 5:51 PMKevin Su
12/22/2022, 12:16 AMLaura Lin
01/11/2023, 1:45 AM