Function collectTraces

worker/scripts/run-long-lived-workflow.ts:106–116

(pool: Pool, runId: string)

}

async function collectTraces(pool: Pool, runId: string): Promise<TraceRow[]> {
  const result = await pool.query<TraceRow>(
    `SELECT sequence, node_ref, type, timestamp, level, message, error
     FROM workflow_traces
     WHERE run_id = $1
     ORDER BY sequence ASC`,
    [runId],
  );

  return result.rows;
}

async function main() {
  const pool = new Pool({ connectionString: DATABASE_URL });