Function runParallelPlan

src/session/parallel_executor.js:157–192

* Run a full plan through the parallel executor. * Processes batches in order; within each batch, steps run concurrently. * * @param {number[][]} batches - from toParallelBatches() * @param {string[]} planSteps - all plan step texts * @param {object[]} systemMessages - shared system prompt mess

(
  batches,
  planSteps,
  systemMessages,
  chatCompletionFn,
  executeToolFn,
  config,
  ctx,
  onBatchComplete,
)

 * @returns {Promise<Array<{stepIndex, content, toolResults}>>}
 */
async function runParallelPlan(
  batches,
  planSteps,
  systemMessages,
  chatCompletionFn,
  executeToolFn,
  config,
  ctx,
  onBatchComplete,
) {
  const allResults = [];

  for (let batchIdx = 0; batchIdx < batches.length; batchIdx++) {
    const batch = batches[batchIdx];
    const batchResults = await executeBatch(
      batch,
      planSteps,
      systemMessages,
      chatCompletionFn,
      executeToolFn,
      config,
      ctx,
    );

    for (const r of batchResults) {
      allResults[r.stepIndex] = r;
    }

    if (typeof onBatchComplete === 'function') {
      try { onBatchComplete(batchIdx, batchResults); } catch {}
    }
  }

  // Return results sorted by original step order
  return allResults.filter(Boolean);
}

/**
 * Merge parallel execution results into a single conversationHistory entry.