Skip to content

Commit 8a85207

Browse files
authoredFeb 17, 2024··
fix(flow): remove failed children references on auto removal (#2432)
1 parent 83e8a61 commit 8a85207

File tree

1 file changed

+7
-3
lines changed

1 file changed

+7
-3
lines changed
 

‎src/commands/moveToFinished-14.lua

+7-3
Original file line numberDiff line numberDiff line change
@@ -58,18 +58,19 @@ local rcall = redis.call
5858
--- Includes
5959
--- @include "includes/collectMetrics"
6060
--- @include "includes/getNextDelayedTimestamp"
61+
--- @include "includes/getRateLimitTTL"
6162
--- @include "includes/getTargetQueueList"
6263
--- @include "includes/moveJobFromPriorityToActive"
63-
--- @include "includes/prepareJobForProcessing"
6464
--- @include "includes/moveParentFromWaitingChildrenToFailed"
6565
--- @include "includes/moveParentToWaitIfNeeded"
66+
--- @include "includes/prepareJobForProcessing"
6667
--- @include "includes/promoteDelayedJobs"
68+
--- @include "includes/removeJobKeys"
6769
--- @include "includes/removeJobsByMaxAge"
6870
--- @include "includes/removeJobsByMaxCount"
6971
--- @include "includes/removeParentDependencyKey"
7072
--- @include "includes/trimEvents"
7173
--- @include "includes/updateParentDepsIfNeeded"
72-
--- @include "includes/getRateLimitTTL"
7374

7475
local jobIdKey = KEYS[12]
7576
if rcall("EXISTS", jobIdKey) == 1 then -- // Make sure job exists
@@ -183,8 +184,11 @@ if rcall("EXISTS", jobIdKey) == 1 then -- // Make sure job exists
183184
removeJobsByMaxCount(maxCount, targetSet, prefix)
184185
end
185186
else
186-
rcall("DEL", jobIdKey, jobIdKey .. ':logs', jobIdKey .. ':processed')
187+
removeJobKeys(jobIdKey)
187188
if parentKey ~= "" then
189+
-- TODO: when a child is removed when finished, result or failure in parent
190+
-- must not be deleted, those value references should be deleted when the parent
191+
-- is deleted
188192
removeParentDependencyKey(jobIdKey, false, parentKey)
189193
end
190194
end

0 commit comments

Comments
 (0)
Please sign in to comment.