Method prepareInputMessage

pkg/workflow/actor_engine.go:623–631

(execution *WorkflowExecution, node *NodeDef)

}

func (c *CoordinatorActor) prepareInputMessage(execution *WorkflowExecution, node *NodeDef) (string, error) {
	// 简化实现
	if len(execution.Context.Inputs) > 0 {
		if input, ok := execution.Context.Inputs["message"].(string); ok {
			return input, nil
		}
	}
	return "", nil
}

// ============== 协调器消息类型 ==============