fix: fixed reprocess lua script

taskforcesh · Aug 24, 2019 · b78296f · b78296f
1 parent a3f6148
commit b78296f
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/src/commands/reprocessJob-4.lua b/src/commands/reprocessJob-4.lua
@@ -18,10 +18,11 @@
   Events:
     emits 'added' if succesfully moved job to wait.
 ]]
-if (redis.call("EXISTS", KEYS[1]) == 1) then
-    if (redis.call("ZREM", KEYS[3], ARGV[1]) == 1) then
-      redis.call(ARGV[2], KEYS[4], ARGV[1])
-      redis.call(ARGV[2], KEYS[4] .. ":added", ARGV[1])
+local rcall = redis.call;
+if (rcall("EXISTS", KEYS[1]) == 1) then
+    if (rcall("ZREM", KEYS[3], ARGV[1]) == 1) then
+      rcall(ARGV[2], KEYS[4], ARGV[1])
+      rcall(ARGV[2], KEYS[4] .. ":added", ARGV[1])
 
       -- Emit waiting event
       rcall("XADD", KEYS[2], "*", "event", "waiting", "jobId", jobId);