| 1234567891011121314 |
- --[[
- Validate and move parent to a wait status (waiting, delayed or prioritized) if needed.
- ]]
- -- Includes
- --- @include "moveParentToWait"
- local function moveParentToWaitIfNeeded(parentQueueKey, parentKey, parentId, timestamp)
- if rcall("EXISTS", parentKey) == 1 then
- local parentWaitingChildrenKey = parentQueueKey .. ":waiting-children"
- if rcall("ZSCORE", parentWaitingChildrenKey, parentId) then
- rcall("ZREM", parentWaitingChildrenKey, parentId)
- moveParentToWait(parentQueueKey, parentKey, parentId, timestamp)
- end
- end
- end
|