handleNodeCompleted 处理节点完成
(ctx *actor.Context, msg *NodeCompletedMsg)
| 528 | |
| 529 | // handleNodeCompleted 处理节点完成 |
| 530 | func (c *CoordinatorActor) handleNodeCompleted(ctx *actor.Context, msg *NodeCompletedMsg) { |
| 531 | wfLog.Debug(context.Background(), "node completed", map[string]any{"node_id": msg.NodeID, "execution_id": msg.ExecutionID}) |
| 532 | } |
| 533 | |
| 534 | // handleNodeFailed 处理节点失败 |
| 535 | func (c *CoordinatorActor) handleNodeFailed(ctx *actor.Context, msg *NodeFailedMsg) { |