Function TestExecuteParallel

pkg/executionplan/executor_test.go:283–325

(t *testing.T)

}

func TestExecuteParallel(t *testing.T) {
	// Use delays to verify parallel execution
	tool1 := newDelayedMockTool("tool1", "result1", 50*time.Millisecond)
	tool2 := newDelayedMockTool("tool2", "result2", 50*time.Millisecond)
	tool3 := newDelayedMockTool("tool3", "result3", 50*time.Millisecond)

	toolMap := map[string]tools.Tool{
		"tool1": tool1,
		"tool2": tool2,
		"tool3": tool3,
	}

	executor := NewExecutor(toolMap)

	plan := NewExecutionPlan("Parallel test")
	plan.AddStep("tool1", "Step 1", nil)
	plan.AddStep("tool2", "Step 2", nil)
	plan.AddStep("tool3", "Step 3", nil)
	plan.Options.RequireApproval = false
	plan.Options.AllowParallel = true
	plan.Options.MaxParallelSteps = 3

	ctx := context.Background()
	toolCtx := &tools.ToolContext{AgentID: "test-agent"}

	start := time.Now()
	err := executor.Execute(ctx, plan, toolCtx)
	duration := time.Since(start)

	if err != nil {
		t.Fatalf("unexpected error: %v", err)
	}

	// If executed sequentially, it would take ~150ms
	// If executed in parallel, it should take ~50-70ms
	if duration > 120*time.Millisecond {
		t.Errorf("parallel execution took too long: %v (expected < 120ms)", duration)
	}

	if plan.Status != StatusCompleted {
		t.Errorf("expected status %v, got %v", StatusCompleted, plan.Status)
	}
}

func TestExecuteWithDependencies(t *testing.T) {
	tool1 := newMockTool("tool1", "result1", nil)