fix: guard worker node back pressure flag change

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
poolifier · May 8, 2024 · 6538ac5 · 6538ac5
1 parent f621cf4
commit 6538ac5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/pools/worker-node.ts b/src/pools/worker-node.ts
@@ -104,8 +104,8 @@ export class WorkerNode<Worker extends IWorker, Data = unknown>
  detail: { workerId: this.info.id },
  }),
  )
+ this.setBackPressureFlag = false
  }
- this.setBackPressureFlag = false
  return tasksQueueSize
  }
 
@@ -119,8 +119,8 @@ export class WorkerNode<Worker extends IWorker, Data = unknown>
  ) {
  this.setBackPressureFlag = true
  this.info.backPressure = false
+ this.setBackPressureFlag = false
  }
- this.setBackPressureFlag = false
  return task
  }