Method canExecuteNode

pkg/workflow/engine.go:761–783

canExecuteNode 检查节点是否可以执行

(execution *WorkflowExecution, nodeID string, condition string)

// canExecuteNode 检查节点是否可以执行
func (e *Engine) canExecuteNode(execution *WorkflowExecution, nodeID string, condition string) bool {
	// 检查节点是否已完成
	if execution.CompletedNodes[nodeID] {
		return false
	}

	// 检查节点是否失败
	if _, failed := execution.FailedNodes[nodeID]; failed {
		return false
	}

	// 检查边条件
	if condition != "" {
		evaluator := NewExpressionEvaluator(execution.Context.Variables)
		result, err := evaluator.EvaluateBool(condition)
		if err != nil {
			return false
		}
		return result
	}

	return true
}

// prepareInputMessage 准备输入消息
func (e *Engine) prepareInputMessage(execution *WorkflowExecution, node *NodeDef) (string, error) {