Function TestTaskTool_ConcurrentSubagentLaunch

pkg/tools/builtin/task_test.go:251–290

(t *testing.T)

}

func TestTaskTool_ConcurrentSubagentLaunch(t *testing.T) {
	if testing.Short() {
		t.Skip("Skipping concurrent subagent test in short mode")
	}

	tool, err := NewTaskTool(nil)
	if err != nil {
		t.Fatalf("Failed to create Task tool: %v", err)
	}

	concurrency := 3
	result := RunConcurrentTest(concurrency, func() error {
		input := map[string]any{
			"subagent_type":   "general-purpose",
			"prompt":          "Concurrent test task",
			"timeout_minutes": 1,
		}

		result := ExecuteToolWithInput(t, tool, input)
		if !result["ok"].(bool) {
			return errors.New("Task launch failed")
		}

		// 验证task_id不为空
		taskID := result["task_id"].(string)
		if taskID == "" {
			return errors.New("Empty task_id returned")
		}

		return nil
	})

	if result.ErrorCount > 0 {
		t.Errorf("Concurrent subagent launch failed: %d errors out of %d attempts",
			result.ErrorCount, concurrency)
	}

	t.Logf("Concurrent subagent launch completed: %d success, %d errors in %v",
		result.SuccessCount, result.ErrorCount, result.Duration)
}

func TestTaskTool_PerformanceInfo(t *testing.T) {
	tool, err := NewTaskTool(nil)