varsha Parthasarathy
10/11/2022, 1:53 PMmap_task_partition_outputs = flytekit.map_task(process_map_task_partition, concurrency=300)(
map_task_partition=map_task_partitions).with_overrides(
limits=flytekit.Resources(cpu="4", mem="42Gi"),
requests=flytekit.Resources(cpu="4", mem="42Gi"),
retries=3,
)
Example,== ^^^ is one of our map task function call.Samhita Alla
Yee
varsha Parthasarathy
10/11/2022, 7:56 PMYee
katrina
varsha Parthasarathy
10/11/2022, 9:00 PM