Refactor

graphile · Jun 6, 2024 · f46ec8d · f46ec8d
1 parent 8fb0174
commit f46ec8d
Showing 1 changed file with 15 additions and 13 deletions.
diff --git a/src/main.ts b/src/main.ts
@@ -899,19 +899,21 @@ export function _runTaskList(
       // Queue is empty, no fetch of jobs in progress; let's fetch them.
       getJobBaseline = getJobCounter;
       nextJobs = (async () => {
-        const jobs = await baseGetJob(
-          compiledSharedOptions,
-          withPgClient,
-          tasks,
-          workerPool.id,
-          null,
-          getJobBatchSize,
-        );
-        jobQueue = jobs.reverse();
-        return jobs.length >= getJobBatchSize;
-      })().finally(() => {
-        nextJobs = null;
-      });
+        try {
+          const jobs = await baseGetJob(
+            compiledSharedOptions,
+            withPgClient,
+            tasks,
+            workerPool.id,
+            null,
+            getJobBatchSize,
+          );
+          jobQueue = jobs.reverse();
+          return jobs.length >= getJobBatchSize;
+        } finally {
+          nextJobs = null;
+        }
+      })();
     }
     const fetchedMax = await nextJobs;
     const job = jobQueue.pop();