fix(worker): return minimumBlockTimeout depending on redis version (p…

…ython) (#2532)
taskforcesh · Apr 20, 2024 · 83dfb63 · 83dfb63
1 parent 333c3e0
commit 83dfb63
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/python/bullmq/worker.py b/python/bullmq/worker.py
@@ -170,7 +170,7 @@ def getBlockTimeout(self, block_until: int):
             block_timeout = None
             block_delay = block_until - int(time.time() * 1000)
             if block_delay < self.minimumBlockTimeout * 1000:
-                block_timeout = minimum_block_timeout
+                return self.minimumBlockTimeout
             else:
                 block_timeout = block_delay / 1000
             # We restrict the maximum block timeout to 10 second to avoid

diff --git a/src/classes/worker.ts b/src/classes/worker.ts
@@ -660,7 +660,7 @@ export class Worker<
       const blockDelay = blockUntil - Date.now();
       // when we reach the time to get new jobs
       if (blockDelay < this.minimumBlockTimeout * 1000) {
-        blockTimeout = minimumBlockTimeout;
+        return this.minimumBlockTimeout;
       } else {
         blockTimeout = blockDelay / 1000;
       }