Function main

worker/scripts/benchmark-scheduler.ts:232–292

()

}

async function main() {
  const iterations = Number.parseInt(process.env.BENCHMARK_ITERATIONS ?? '3', 10);

  const connection = await Connection.connect({ address: TEMPORAL_ADDRESS });
  const client = new Client({ connection, namespace: TEMPORAL_NAMESPACE });

  try {
    console.log(`Running benchmark with ${iterations} iteration(s) per mode...`);

    const inlineSerial = await runInlineBenchmark(serialDefinition, iterations, 'serial');
    const inlineParallel = await runInlineBenchmark(parallelDefinition, iterations, 'parallel');
    const temporalSerial = await runTemporalBenchmark(
      client,
      serialDefinition,
      iterations,
      'serial',
    );
    const temporalParallel = await runTemporalBenchmark(
      client,
      parallelDefinition,
      iterations,
      'parallel',
    );

    const summaryRows = [inlineSerial, inlineParallel, temporalSerial, temporalParallel].map(
      (result) => ({
        Engine: result.engine,
        Mode: result.mode,
        Runs: result.runs,
        'Average (ms)': result.averageMs.toFixed(2),
      }),
    );

    console.table(summaryRows);

    await ensureOutputDir();
    const snapshotPath = join(OUTPUT_DIR, `scheduler-benchmark-${Date.now()}.json`);
    await fs.writeFile(
      snapshotPath,
      JSON.stringify(
        {
          iterations,
          inline: {
            serial: inlineSerial,
            parallel: inlineParallel,
          },
          temporal: {
            serial: temporalSerial,
            parallel: temporalParallel,
          },
        },
        null,
        2,
      ),
      'utf8',
    );
    console.log(`Benchmark snapshot written to ${snapshotPath}`);
  } finally {