fix(workflow): close stale reaper races

Author: Waishnav

src/workflow-lifecycle.ts

@@ -115,13 +115,14 @@ export function startWorkflowReaper(
   const staleAfterMs = Math.max(1, options.staleAfterMs ?? DEFAULT_STALE_AFTER_MS);
 
   const tick = (): void => {
-    const store = createWorkflowStore(config);
+    let store: WorkflowStore | undefined;
     try {
+      store = createWorkflowStore(config);
       reapStaleWorkflows(store, staleAfterMs);
     } catch (error) {
       options.onError?.(error);
     } finally {
-      store.close();
+      store?.close();
     }
   };
 

src/workflow-store.ts

@@ -764,9 +764,9 @@ export class WorkflowStore {
 
     const reaped: WorkflowRunRecord[] = [];
     for (const row of candidates) {
-      if (row.pid !== null && isPidAlive(row.pid)) continue;
       const latest = this.getRun(row.id);
       if (!latest || (latest.status !== "running" && latest.status !== "starting")) continue;
+      if (latest.pid !== undefined && isPidAlive(latest.pid)) continue;
       const failed = this.failRun(row.id, {
         error: latest.status === "starting" ? "workflow worker failed to start" : "worker heartbeat lost",
         errorKind: "heartbeat",