第33章:Workflow 图引擎源码完全剖析
1. 项目背景第 22 章我们阅读了 WorkflowEntry 入口和拓扑排序。本章深入GraphEngine的全部核心源码——理解图如何从 JSON DSL 构建为可执行对象、线程池如何调度并行节点、变量池如何注册节点输出、节点失败时图如何处理、以及如何添加进度事件。读完本章你将能够:修改 GraphEngine 添加自定义行为(如进度百分比、允许部分节点失败后继续)、理解"为什么有些节点没有并行执行"的根因、为自定义节点写入正确的执行上下文。核心源码文件:api/core/workflow/workflow_entry.py:入口 + GraphEngine 类api/core/workflow/node_factory.py:节点工厂,类型注册与实例化api/core/workflow/node_runtime.py:节点运行时状态(封装了输入获取/输出注册)api/core/workflow/variable_pool_initializer.py:变量池2. 项目设计小胖:(看着 Workflow 执行日志)“大师!我 20 个节点的 Workflow,理论上步骤 3 和步骤 4 应该同时执行(它们不互相依赖),但日志显示是先后执行的。为什么没有并行?”大师