Limit concurrency of pds background tasks (bluesky-social#917)

MaxGraey · Apr 27, 2023 · 7d1243f · 7d1243f
1 parent 384e739
commit 7d1243f
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/packages/pds/src/event-stream/background-queue.ts b/packages/pds/src/event-stream/background-queue.ts
@@ -5,10 +5,13 @@ import { dbLogger } from '../logger'
 // A simple queue for in-process, out-of-band/backgrounded work
 
 export class BackgroundQueue {
-  queue = new PQueue()
+  queue = new PQueue({ concurrency: 10 })
   constructor(public db: Database) {}
 
   add(task: Task) {
+    if (this.queue.isPaused) {
+      return
+    }
     this.queue
       .add(() => task(this.db))
       .catch((err) => {