| 动态映射 | partial(...).expand(param=[...]) |
|---|---|
| 数量保护 | 可配置映射任务数上限 |
| TaskGroup | 逻辑分组、界面折叠显示 |
| 依赖声明 | 可整体引用 group 或逐个任务声明 |
expand 与 TaskGroup
expand 与 TaskGroup
@task
def load(part: str) -> None:
print(part)
@task_group(group_id="loads")
def make_group(parts):
load.expand(part=parts)
make_group(["dt=2026-10-09", "dt=2026-10-10"])映射任务数在运行前就能从入参推出，不要把展开列表写成会随数据无限增长的来源。