Function main

worker/scripts/run-long-lived-workflow.ts:118–160

()

}

async function main() {
  const pool = new Pool({ connectionString: DATABASE_URL });
  const connection = await Connection.connect({ address: TEMPORAL_ADDRESS });
  const client = new Client({ connection, namespace: TEMPORAL_NAMESPACE });

  try {
    const runId = `long-lived-${randomUUID()}`;
    console.log(`Starting long-lived workflow ${runId}`);
    const start = Date.now();

    const handle = await client.workflow.start(shipsecWorkflowRun, {
      workflowId: runId,
      taskQueue: TEMPORAL_TASK_QUEUE,
      args: [
        {
          runId,
          workflowId: 'long-lived-synthetic',
          definition: longLivedDefinition,
          inputs: {},
        },
      ],
    });

    const result = await handle.result();
    const durationMs = Date.now() - start;
    console.log(`Workflow completed in ${durationMs}ms`);

    const traces = await collectTraces(pool, runId);
    await ensureOutputDir();
    const snapshotPath = join(OUTPUT_DIR, `long-lived-trace-${runId}.json`);
    await fs.writeFile(
      snapshotPath,
      JSON.stringify({ runId, durationMs, completed: result, traces }, null, 2),
      'utf8',
    );

    console.log(`Trace snapshot written to ${snapshotPath}`);
    console.log(`Trace events captured: ${traces.length}`);
  } finally {
    await client.connection.close();
    await pool.end();
  }
}

if (import.meta.main) {
  main().catch((err) => {