| 123456789101112131415 |
- --[[
- Function to move job to wait to be picked up by a waiting worker.
- ]]
- -- Includes
- --- @include "addJobInTargetList"
- --- @include "getTargetQueueList"
- local function moveJobToWait(metaKey, activeKey, waitKey, pausedKey, markerKey, eventStreamKey,
- jobId, pushCmd)
- local target, isPausedOrMaxed = getTargetQueueList(metaKey, activeKey, waitKey, pausedKey)
- addJobInTargetList(target, markerKey, pushCmd, isPausedOrMaxed, jobId)
- rcall("XADD", eventStreamKey, "*", "event", "waiting", "jobId", jobId, 'prev', 'active')
- end
|