Function runTemporalBenchmark

worker/scripts/benchmark-scheduler.ts:158–196

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

};

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

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

    const handle = await client.workflow.start(shipsecWorkflowRun, {
      workflowId: runId,
      taskQueue: TEMPORAL_TASK_QUEUE,
      args: [
        {
          runId,
          workflowId: `benchmark-${label}`,
          definition,
          inputs: {},
        },
      ],
    });

    await handle.result();
    durations.push(Date.now() - start);
  }

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

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

async function ensureOutputDir() {
  await fs.mkdir(OUTPUT_DIR, { recursive: true });