Flyte enables production-grade orchestration for machine learning workflows and data processing created to accelerate local workflows to production.

Flyte

Screenshot 2023-12-05 at 16.50.59.png

Quick question about surprising behaviour of map tasks:

Code snippet in the :thread:

Does anyone know why for an input list of length 5, `list_q: list[int] = [1, 2, 3, 4, 5]`, there are 10 executions according to the UI? There also have been only 5 pods.

```import functools
from flytekit import map_task, task, workflow


@task
def multi_input_task(quantity: int, price: float, shipping: float) -&gt; float:
    return quantity * price * shipping


@workflow
def multiple_workflow(list_q: list[int] = [1, 2, 3, 4, 5], p: float = 6.0, s: float = 7.0) -&gt; list[float]:
    partial_task = functools.partial(multi_input_task, price=p, shipping=s)
    return map_task(partial_task)(quantity=list_q)```

<https://docs.flyte.org/projects/cookbook/en/latest/auto_examples/advanced_composition/map_task.html#map-a-task-with-multiple-inputs|Example> taken from the docs.

Think there's already an issue for this (maybe check). I think it is a UI bug where multiple log links are reported for each task, so each link is shown individually.

I searched through all issues found for the query “map task” but didn’t find anything among those. (Hope I didnt overlook it)

I’ll create a new issue then.

I can confirm that the number of shown executions is the multiplication of the actual number of pods times the number of configured log links per pod.

<https://github.com/flyteorg/flyte/issues/4531>