本文详解 flyte 中 `map_task` 实现真正并行执行的关键前提——必须在远程 flyte 后端（而非本地执行）运行，同时推荐采用新版 `flytekit.experimental.map_task` 以获得更稳定、可扩展的并行能力。
在 Flyte 中，map_task 是专为批量、独立、可并行化任务设计的核心抽象。但一个常见误区是：开发者在本地开发环境中调用 pyflyte run 或直接执行 workflow 时，误以为 map_task 会触发多线程或多进程并发——实际上，FlyteKit 的本地执行模式（local execution）目前完全不支持并行调度，所有 mapped 任务会严格串行执行（即使逻辑上彼此独立），这正是你观察到“无法并行”的根本原因。
✅ 正确做法：仅在部署到真实 Flyte 后端（如 FlyteAdmin + K8s 集群）时，map_task 才会被编译为并行 DAG 节点，并由 FlytePropeller 调度器分发至多个 Pod 并发执行。
此外，Flyte 官方已在 v1.12+ 版本中将更健壮的新版 map_task 移入 flytekit.experimental 模块，它修复了旧版在类型推导、错误传播和资源隔离方面的若干问题，并将成为未来默认实现：
from flytekit import task, workflow
from flytekit.experimental import map_task # ✅ 推荐：使用 experimental 版本
import time
@task
def do_something(value: str) -> str:
print(f"Started processing: {value}", flush=True)
time.sleep(60) # 模拟耗时任务
return f"{value}-processed"
@workflow
def do_multiple_things() -> list[str]:
values = ["foo", "bar", "baz"]
# 注意：参数名需与 task 签名严格匹配（此处为 value）
return map_task(do_something)(value=values)⚠️ 关键注意事项：
- 本地调试 ≠ 真实并行：pyflyte run --remote ...（指向远程 cluster）才能触发并行；pyflyte run（无 --remote）始终串行。
- 输入必须为 List：map_task 仅接受 List[T] 类型输入，且子任务函数签名中对应参数必须声明为单个元素类型 T（如 value: str）。
- 资源隔离保障：每个 mapped 子任务在远程执行时均独占 Pod，天然具备 CPU/内存/网络隔离，避免串行竞争。
- 错误处理策略：默认采用“失败即中断”（fail-fast），若需容错，可结合 @task(retries=1) 或后续使用 flytekit.types.structured_dataset.StructuredDataset 进行批处理级恢复。
总结：要让 Flyte 真正并行，请务必完成两步——（1）升级至 flytekit>=1.12 并导入 flytekit.experimental.map_task；（2）通过 --remote 将 workflow 注册并提交至生产级 Flyte 集群。本地开发阶段可借助 @task(cache=True) 加速重复测试，但并行性验证必须依赖远程环境。
