Method executeSequential

pkg/executionplan/executor.go:127–174

executeSequential 顺序执行步骤

(ctx context.Context, plan *ExecutionPlan, toolCtx *tools.ToolContext)

// executeSequential 顺序执行步骤
func (e *Executor) executeSequential(ctx context.Context, plan *ExecutionPlan, toolCtx *tools.ToolContext) error {
	var firstError error

	for i := range plan.Steps {
		select {
		case <-ctx.Done():
			// 上下文取消，标记剩余步骤为跳过
			for j := i; j < len(plan.Steps); j++ {
				plan.Steps[j].Status = StepStatusSkipped
			}
			return ctx.Err()
		default:
		}

		step := &plan.Steps[i]

		// 跳过已完成的步骤（用于恢复执行）
		if step.Status == StepStatusCompleted {
			continue
		}

		// 检查依赖是否满足
		if !e.checkDependencies(plan, step) {
			step.Status = StepStatusSkipped
			step.Error = "dependencies not satisfied"
			continue
		}

		// 执行步骤
		err := e.executeStep(ctx, plan, step, toolCtx)
		if err != nil {
			if firstError == nil {
				firstError = err
			}

			// 根据配置决定是否继续
			if plan.Options != nil && plan.Options.StopOnError {
				// 标记剩余步骤为跳过
				for j := i + 1; j < len(plan.Steps); j++ {
					plan.Steps[j].Status = StepStatusSkipped
				}
				return err
			}
		}
	}

	return firstError
}

// executeParallel 并行执行无依赖的步骤
func (e *Executor) executeParallel(ctx context.Context, plan *ExecutionPlan, toolCtx *tools.ToolContext) error {