Hi, I'm wondering if `map_task` supports ContainerTask. Looks like <this> was never merged.
c
Hi, I'm wondering if
map_task
supports ContainerTask. Looks like this was never merged.
a
Yes, MapTasks in its current implementation (ArrayNode) supports mapping over plugins beyond just Kubernetes, and that includes ContainerTasks
c
I got this error though when I tried the following. I'm on flytekit 1.12.3.
Copy code
Traceback (most recent call last):

      File "/fn/lib/venv/lib/python3.11/site-packages/flytekit/exceptions/scopes.py", line 242, in user_entry_point
        return wrapped(*args, **kwargs)
               ^^^^^^^^^^^^^^^^^^^^^^^^
      File "/usr/src/app/flyte_ngs_recipes/examples/raw_container_tasks.py", line 157, in downsample_bams_and_find_regions
        downsampled_bams = map_task(
                           ^^^^^^^^^
      File "/fn/lib/venv/lib/python3.11/site-packages/flytekit/core/array_node_map_task.py", line 365, in map_task
        return ArrayNodeMapTask(task_function, concurrency=concurrency, min_success_ratio=min_success_ratio, **kwargs)
               ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
      File "/fn/lib/venv/lib/python3.11/site-packages/flytekit/core/tracker.py", line 85, in __call__
        o = super(InstanceTrackingMeta, cls).__call__(*args, **kwargs)
            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
      File "/fn/lib/venv/lib/python3.11/site-packages/flytekit/core/array_node_map_task.py", line 63, in __init__
        raise ValueError("Only PythonFunctionTask and PythonInstanceTask are supported in map tasks.")

Message:

    ValueError: Only PythonFunctionTask and PythonInstanceTask are supported in map tasks.

User error.
a
cc @flat-area-42876