fix(update-progress): remove old updateProgress script to prevent con…

…flict (#2298) (python)
taskforcesh · Nov 26, 2023 · e65b819 · e65b819
1 parent d7cf6ea
commit e65b819
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 28 deletions.
diff --git a/python/bullmq/scripts.py b/python/bullmq/scripts.py
@@ -55,7 +55,7 @@ def __init__(self, prefix: str, queueName: str, redisConnection: RedisConnection
             "moveJobsToWait": self.redisClient.register_script(self.getScript("moveJobsToWait-6.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-2.lua")),
+            "updateProgress": self.redisClient.register_script(self.getScript("updateProgress-3.lua")),
         }
 
         self.queue_keys = QueueKeys(prefix)
@@ -417,7 +417,7 @@ def moveToFailed(self, job: Job, failedReason: str, removeOnFailed, token: str,
         return self.moveToFinished(job, failedReason, "failedReason", removeOnFailed, "failed", token, opts, fetchNext)
 
     async def updateProgress(self, job_id: str, progress):
-        keys = [self.toKey(job_id), self.keys['events']]
+        keys = [self.toKey(job_id), self.keys['events'], self.keys['meta']]
         progress_json = json.dumps(progress, separators=(',', ':'))
         args = [job_id, progress_json]
         result = await self.commands["updateProgress"](keys=keys, args=args)

diff --git a/src/commands/updateProgress-2.lua b/src/commands/updateProgress-2.lua