flytekit.map_task#

flytekit.map_task(target, concurrency=None, min_successes=None, min_success_ratio=1.0, **kwargs)[source]#

Wrapper that creates a map task utilizing either the existing ArrayNodeMapTask or the drop in replacement ArrayNode implementation

Parameters:

  • target (LaunchPlan | PythonFunctionTask | FlyteLaunchPlan) – The Flyte entity of which will be mapped over

  • concurrency (int | None) – If specified, this limits the number of mapped tasks than can run in parallel to the given batch size. If the size of the input exceeds the concurrency value, then multiple batches will be run serially until all inputs are processed. If set to 0, this means unbounded concurrency. If left unspecified, this means the array node will inherit parallelism from the workflow

  • min_successes (int | None) – The minimum number of successful executions

  • min_success_ratio (float) – The minimum ratio of successful executions