工作流与 Lineage API

工作流 API 管理界面可见的流程定义及其执行；Lineage API 用于检查处理产生的产物和 Revision。两者相关但回答的问题不同：执行状态说明任务是否运行成功，Lineage 说明 产物从哪里来、又被谁依赖。

工作流定义

当前产品契约的根路径是：

/newmoi/workflow/v2/workflow-apps

方法与路径

用途

GET /newmoi/workflow/v2/workflow-apps

列出工作流应用

POST /newmoi/workflow/v2/workflow-deployments

从定义部署界面可见的工作流

GET /newmoi/workflow/v2/workflow-apps/:workflow_id

读取工作流

PATCH /newmoi/workflow/v2/workflow-apps/:workflow_id

更新已保存定义

DELETE /newmoi/workflow/v2/workflow-apps/:workflow_id

删除工作流

POST .../:workflow_id/pause

阻止新的执行

POST .../:workflow_id/resume

恢复接收执行

部署结果会返回后续 workflow-apps 接口使用的工作流 ID。已保存的 DSL 是执行真值。 更新前应校验必填 WorkItem ID、输入输出类型、依赖关系和 循环终止条件。可用 WorkItem 由工作区决定，应查询部署环境的 WorkItem 目录，不要从 静态示例复制 ID。

工作流模板使用 /newmoi/workflow-templates，支持列表、创建、详情、更新和删除。 模板只是可复用的设计材料，不能证明工作流已经部署或运行。

启动并检查执行

使用以下接口创建执行：

POST /newmoi/workflow/v2/workflow-apps/:workflow_id/executions

执行接口族提供列表 / 详情、刷新、暂停、恢复、结果、导入上下文、导入文件、节点详情、 重试、取消与删除。保存返回的 execution ID；不要只根据时间或显示名称选择一次运行。

通过执行时间线区分上游等待与计算资源排队。启动请求返回成功，只表示执行已被接受， 不代表所有节点成功；消费输出前必须读取终态执行及其结果。

节点重跑

从节点重跑时：

  1. 读取 .../nodes/:node_key/rerun-plan。

  2. 检查受影响的下游分支、节点副作用和可复用输出。

  3. 通过 .../nodes/:node_key/reruns 创建重跑。

  4. 使用返回的 rerun ID 查询 .../reruns/:rerun_id；需要时通过其 /cancel 动作取消。

输入无效、DSL 错误可稳定复现，或外部副作用可能已经完成时，不要自动用重跑掩盖问题。

Lineage 与 Revision

路径族

返回内容

GET /newmoi/lineage/catalog-files/:file_id/overview

文件级处理概览

/newmoi/lineage/artifacts/:artifact_id/overview

产物级概览

.../output-blocks

产出的 Block

.../blocks/:block_id/revisions

可用 Revision 及 Revision 创建

.../effective-revisions

选择生效 Revision

.../nodes/:node_id

节点详情及节点输出 Block

.../nodes/:node_id/rerun

从产物节点重跑

.../output-emissions/.../rerun-with-revisions

使用指定 Revision 重跑

切换 Revision 会改变下游操作视为有效的产物内容。变更前应立即读取当前 Revision； 可能影响下游结果时，需要调用者明确确认。

自定义算子与 WorkItem API Service 也属于工作流领域，但其发布和调用 Schema 随部署 变化。输入输出 Schema、计算资源绑定、超时、并发、限流、启停和调用 Payload 均应以 目标环境 OpenAPI 为准。

Worker 容量与指标见计算资源与告警；文件产物见 数据、文件与连接器。

最后更新于