Function runInlineBenchmark

worker/scripts/benchmark-scheduler.ts:202–230

(
  definition: WorkflowDefinition,
  iterations: number,
  label: BenchmarkMode,
)

}

async function runInlineBenchmark(
  definition: WorkflowDefinition,
  iterations: number,
  label: BenchmarkMode,
): Promise<BenchmarkResult> {
  const durations: number[] = [];

  for (let i = 0; i < iterations; i += 1) {
    const runId = `${label}-inline-${randomUUID()}`;
    const start = Date.now();

    const result = await executeWorkflow(definition, {}, { runId });
    if (!result.success) {
      throw new Error(`Inline benchmark ${label} failed: ${result.error}`);
    }

    durations.push(Date.now() - start);
  }

  const averageMs = durations.reduce((sum, value) => sum + value, 0) / durations.length;

  return {
    engine: 'inline',
    mode: label,
    runs: iterations,
    durations,
    averageMs,
  };
}

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