Function collectResults

server/src/utils/batch.ts:163–185

* Stream JSONL results from a completed batch and return as a Map.

(
  client: Anthropic,
  batch: MessageBatch,
  operationName: string,
)

 * Stream JSONL results from a completed batch and return as a Map.
 */
async function collectResults(
  client: Anthropic,
  batch: MessageBatch,
  operationName: string,
): Promise<Map<string, BatchItemResult>> {
  const results = new Map<string, BatchItemResult>();
  const decoder = await client.messages.batches.results(batch.id);

  for await (const entry of decoder) {
    const item = toBatchItemResult(entry);
    results.set(item.customId, item);
  }

  let succeeded = 0;
  results.forEach((r) => { if (r.status === 'succeeded') succeeded++; });
  const failed = results.size - succeeded;
  logger.info(
    { batchId: batch.id, succeeded, failed, operation: operationName },
    'Batch results collected',
  );

  return results;
}

/**
 * Convert an SDK batch result entry to our BatchItemResult.