refactor: update scripts in python

taskforcesh · Jan 12, 2024 · beb63bd · beb63bd
1 parent b7318c7
commit beb63bd
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/python/bullmq/scripts.py b/python/bullmq/scripts.py
@@ -54,7 +54,7 @@ def __init__(self, prefix: str, queueName: str, redisConnection: RedisConnection
             "removeJob": self.redisClient.register_script(self.getScript("removeJob-1.lua")),
             "reprocessJob": self.redisClient.register_script(self.getScript("reprocessJob-6.lua")),
             "retryJob": self.redisClient.register_script(self.getScript("retryJob-10.lua")),
-            "moveJobsToWait": self.redisClient.register_script(self.getScript("moveJobsToWait-6.lua")),
+            "moveJobsToWait": self.redisClient.register_script(self.getScript("moveJobsToWait-7.lua")),
             "saveStacktrace": self.redisClient.register_script(self.getScript("saveStacktrace-1.lua")),
             "updateData": self.redisClient.register_script(self.getScript("updateData-1.lua")),
             "updateProgress": self.redisClient.register_script(self.getScript("updateProgress-3.lua")),
@@ -423,7 +423,7 @@ async def retryJobs(self, state: str, count: int, timestamp: int):
         """
         current_state = state or 'failed'
         keys = self.getKeys(
-            ['', 'events', current_state, 'wait', 'paused', 'meta'])
+            ['', 'events', current_state, 'wait', 'paused', 'meta', 'marker'])
         result = await self.commands["moveJobsToWait"](keys=keys, args=[count or 1000, timestamp or round(time.time()*1000), current_state])
         return result