Function submitBatch

server/src/utils/batch.ts:59–109

(
  client: Anthropic,
  requests: BatchRequest[],
  options: BatchOptions = {},
)

 * Returns results keyed by customId for easy lookup.
 */
export async function submitBatch(
  client: Anthropic,
  requests: BatchRequest[],
  options: BatchOptions = {},
): Promise<Map<string, BatchItemResult>> {
  const {
    pollIntervalMs = DEFAULT_POLL_INTERVAL_MS,
    timeoutMs = DEFAULT_TIMEOUT_MS,
    operationName = 'batch',
  } = options;

  if (requests.length === 0) {
    return new Map();
  }

  if (requests.length > MAX_BATCH_SIZE) {
    throw new Error(
      `Batch size ${requests.length} exceeds API limit of ${MAX_BATCH_SIZE} for ${operationName}`,
    );
  }

  // Submit the batch
  let batch;
  try {
    batch = await client.messages.batches.create({
      requests: requests.map((r) => ({
        custom_id: r.customId,
        params: r.params,
      })),
    });
  } catch (err) {
    throw new Error(
      `Batch submission failed for ${operationName}: ${err instanceof Error ? err.message : err}`,
    );
  }

  logger.info(
    { batchId: batch.id, requestCount: requests.length, operation: operationName },
    'Batch submitted',
  );

  // Poll until complete or timeout
  const completedBatch = await pollForCompletion(client, batch.id, {
    pollIntervalMs,
    timeoutMs,
    operationName,
  });

  // Fetch and parse results
  return collectResults(client, completedBatch, operationName);
}

/**
 * Poll a batch until processing_status is 'ended' or timeout.