用途:在 TrueFoundry 上创建、配置和部署工作流,用于数据处理与机器学习训练流水线,例如 ETL、特征工程、模型训练、批量推理,以及用 cron 调度的周期性批处理任务。工作流基于开源编排平台 Flyte,用 Python 装饰器把任务组织成有向无环图(DAG)。
主要能力:@task 定义最小执行单元,每个任务运行在独立容器中,可配置镜像、Python 版本、pip 包和计算资源;@workflow 组合任务并定义执行顺序与数据流;支持 cron 调度(UTC 时区)、容器任务、map/条件/Spark 等高级模式(详见其 references)。
使用方式:先确认 TFY_BASE_URL、TFY_API_KEY 与 TFY_WORKSPACE_FQN(工作区不可自动选择),安装 pip install "truefoundry[workflow]",并执行 tfy login --host "$TFY_BASE_URL"。定义工作流必须使用 Python SDK,部署可用 tfy deploy workflow --name my-ml-pipeline --file workflow.py --workspace_fqn "$TFY_WORKSPACE_FQN",或用 tfy apply 配合 YAML 清单,CLI 不可用时回退 REST API。部署后需手动触发,仪表盘会显示黄色提示条。
限制:需要 Python 3.9+;目标集群须安装 Flyte 数据平面(控制平面随 TrueFoundry 提供),否则需联系平台管理员;工作流函数只能包含任务调用与控制流,业务逻辑必须放在 @task 中;每个任务的 pip_packages 必须包含 truefoundry[workflow];cron 固定 UTC;容器镜像应固定版本而非 :latest。运行状态包括 QUEUED、RUNNING、SUCCEEDED、FAILED、TIMED_OUT、ABORTED。