chore(queue): remove nested poll call as it leads to memory leaks

mgcrea · May 29, 2024 · 5aaef4d · 5aaef4d
1 parent 1d2ab63
commit 5aaef4d
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 10 deletions.
diff --git a/package.json b/package.json
@@ -60,7 +60,7 @@
     "prettier-plugin-organize-imports": "^3.2.4",
     "prisma": "5.14.0",
     "tsup": "^8.0.2",
-    "tsx": "^4.10.2",
+    "tsx": "^4.11.0",
     "typescript": "^5.4.5",
     "vite-tsconfig-paths": "^4.3.2",
     "vitest": "^1.6.0"

diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml
diff --git a/src/PrismaQueue.ts b/src/PrismaQueue.ts
@@ -214,10 +214,6 @@ export class PrismaQueue<
             .catch((error) => this.emit("error", error))
             .finally(() => {
               this.concurrency--;
-              // Trigger an immediate next job processing if possible.
-              if (this.concurrency < maxConcurrency && !this.stopped) {
-                setImmediate(() => this.poll());
-              }
             }),
         );
         await waitFor(jobInterval);