chore: replace cid in favor of chkey

taskforcesh · Dec 4, 2024 · 7bf0d96 · 7bf0d96
1 parent 53ea54c
commit 7bf0d96
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/src/commands/includes/moveParentFromWaitingChildrenToFailed.lua b/src/commands/includes/moveParentFromWaitingChildrenToFailed.lua
@@ -18,7 +18,7 @@ local function moveParentFromWaitingChildrenToFailed( parentQueueKey, parentKey,
     rcall("XADD", parentQueueKey .. ":events", "*", "event", "failed", "jobId", parentId, "failedReason",
       failedReason, "prev", "waiting-children")
 
-    local jobAttributes = rcall("HMGET", parentKey, "parent", "deid", "opts", "cid")
+    local jobAttributes = rcall("HMGET", parentKey, "parent", "deid", "opts", "chkey")
 
     removeDeduplicationKeyIfNeeded(parentQueuePrefix, jobAttributes[2])
     removeChainKeyIfNeeded(jobAttributes[4], parentKey)

diff --git a/src/commands/includes/removeJob.lua b/src/commands/includes/removeJob.lua
@@ -14,6 +14,6 @@ local function removeJob(jobId, hard, baseKey, shouldRemoveDeduplicationKey)
   if shouldRemoveDeduplicationKey then
     removeDeduplicationKey(baseKey, jobKey)
   end
-  removeChainKeyIfNeeded(rcall("HGET", jobKey, "cid"), jobKey)
+  removeChainKeyIfNeeded(rcall("HGET", jobKey, "chkey"), jobKey)
   removeJobKeys(jobKey)
 end
diff --git a/src/commands/moveStalledJobsToWait-9.lua b/src/commands/moveStalledJobsToWait-9.lua
@@ -81,7 +81,7 @@ if (#stalling > 0) then
                     local stalledCount =
                         rcall("HINCRBY", jobKey, "stalledCounter", 1)
                     if (stalledCount > maxStalledJobCount) then
-                        local jobAttributes = rcall("HMGET", jobKey, "opts", "parent", "deid", "cid")
+                        local jobAttributes = rcall("HMGET", jobKey, "opts", "parent", "deid", "chkey")
                         local rawOpts = jobAttributes[1]
                         local rawParentData = jobAttributes[2]
                         local opts = cjson.decode(rawOpts)

diff --git a/src/commands/removeJob-2.lua b/src/commands/removeJob-2.lua
@@ -69,7 +69,7 @@ local function removeJob(prefix, jobId, parentKey, removeChildren)
     local prev = removeJobFromAnyState(prefix, jobId)
 
     removeDeduplicationKey(prefix, jobKey)
-    removeChainKeyIfNeeded(rcall("HGET", jobKey, "cid"), jobKey)
+    removeChainKeyIfNeeded(rcall("HGET", jobKey, "chkey"), jobKey)
     if removeJobKeys(jobKey) > 0 then
         local maxEvents = getOrSetMaxEvents(KEYS[2])
         rcall("XADD", prefix .. "events", "MAXLEN", "~", maxEvents, "*", "event", "removed", "jobId", jobId, "prev",