set default concurrency to None for backwards compatibility

Signed-off-by: Paul Dittamo <[email protected]>
flyteorg · Apr 10, 2024 · 8a8f4fd · 8a8f4fd
1 parent 451fd03
commit 8a8f4fd
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flytekit/core/array_node_map_task.py b/flytekit/core/array_node_map_task.py
@@ -314,7 +314,7 @@ def _raw_execute(self, **kwargs) -> Any:
 
 def map_task(
     task_function: PythonFunctionTask,
-    concurrency: int = -1,
+    concurrency: Optional[int] = None,
     # TODO why no min_successes?
     min_success_ratio: float = 1.0,
     **kwargs,