Function runParallel

packages/ai-code-mode-skills/test-cli/cli.ts:169–331

* Run tests in parallel with progress display

(
  adaptersToRun: AdapterDefinition[],
  testsToRun: TestDefinition[],
  concurrency: number,
  verbose: boolean,
)

 * Run tests in parallel with progress display
 */
async function runParallel(
  adaptersToRun: AdapterDefinition[],
  testsToRun: TestDefinition[],
  concurrency: number,
  verbose: boolean,
): Promise<AdapterResult[]> {
  // Build task queue
  const tasks: TestTask[] = []
  const resultsMap = new Map<string, AdapterResult>()
  const skippedAdapters: string[] = []

  // Handle tests that don't need an adapter (mock/simulated tests)
  const mockTests = testsToRun.filter((t) => !t.requiresAdapter)
  if (mockTests.length > 0) {
    // Add Mock adapter result for simulated tests
    const mockResult: AdapterResult = {
      adapter: 'Mock',
      tests: {},
    }
    resultsMap.set('mock', mockResult)
    for (const mockTest of mockTests) {
      tasks.push({
        adapterDef: null,
        adapterSet: null,
        test: mockTest,
        verbose,
      })
    }
  }

  // Handle tests that require adapters
  const adapterTests = testsToRun.filter((t) => t.requiresAdapter)

  for (const adapterDef of adaptersToRun) {
    const adapterSet = await adapterDef.create()

    if (!adapterSet) {
      skippedAdapters.push(`${adapterDef.name} (${adapterDef.envKey} not set)`)
      continue
    }

    // Initialize result for this adapter
    const adapterResult: AdapterResult = {
      adapter: adapterDef.name,
      tests: {},
    }
    resultsMap.set(adapterDef.id, adapterResult)

    for (const test of adapterTests) {
      tasks.push({ adapterDef, adapterSet, test, verbose })
    }
  }

  // Show skipped adapters
  if (skippedAdapters.length > 0) {
    console.log(`⚠️  Skipping: ${skippedAdapters.join(', ')}`)
  }