Function enqueueRunMessages

services/auto-routing-benchmark/src/run.ts:122–139

(
  env: Env,
  runId: string,
  messages: { body: BenchmarkJobMessage }[]
)

// Cloudflare Queues caps a single sendBatch at 100 messages. Classifier fan-out
// can exceed that because each classifier case is its own message, so dispatch
// must be sliced.
const QUEUE_SEND_BATCH_LIMIT = 100;

export function chunkArray<T>(items: readonly T[], size: number): T[][] {
  const chunks: T[][] = [];
  for (let i = 0; i < items.length; i += size) {
    chunks.push(items.slice(i, i + size));
  }
  return chunks;
}

export function computeDeciderShardCount({
  modelCount,
  repetitions,
  chunkCount,
  maxLiveContainers = BENCHMARK_CONTAINER_BUDGET,
}: {
  modelCount: number;
  repetitions: number;
  chunkCount: number;