Function groupMutatingForParallel

src/agent/parallel-mutating.ts:59–103

(calls: ToolCall[])

}

export function groupMutatingForParallel(calls: ToolCall[]): ToolCall[][] {
  if (calls.length <= 1) return calls.map(c => [c]);

  const batches: ToolCall[][] = [];
  let currentBatch: ToolCall[] = [];
  let currentPaths: string[] = [];

  for (const tc of calls) {
    const name = tc.function.name;
    // Globals and broad always solo
    if (GLOBAL_TOOLS.has(name) || BROAD_TOOLS.has(name)) {
      if (currentBatch.length > 0) {
        batches.push(currentBatch);
        currentBatch = [];
        currentPaths = [];
      }
      batches.push([tc]);
      continue;
    }
    let args: any;
    try { args = tc.function.arguments ? JSON.parse(tc.function.arguments) : {}; } catch { args = null; }
    const paths = extractPaths(args);
    if (!paths) {
      // Unknown path → conservatively solo
      if (currentBatch.length > 0) {
        batches.push(currentBatch);
        currentBatch = [];
        currentPaths = [];
      }
      batches.push([tc]);
      continue;
    }
    if (pathsConflict(currentPaths, paths)) {
      // Flush current batch, start a new one
      batches.push(currentBatch);
      currentBatch = [tc];
      currentPaths = paths.slice();
    } else {
      currentBatch.push(tc);
      currentPaths.push(...paths);
    }
  }
  if (currentBatch.length > 0) batches.push(currentBatch);
  return batches;
}