| 12345678910111213 |
- --[[
- Validate and move or add dependencies to parent.
- ]]
- -- Includes
- --- @include "moveParentToWaitIfNoPendingDependencies"
- local function updateParentDepsIfNeeded(parentKey, parentQueueKey, parentDependenciesKey,
- parentId, jobIdKey, returnvalue, timestamp )
- local processedSet = parentKey .. ":processed"
- rcall("HSET", processedSet, jobIdKey, returnvalue)
- moveParentToWaitIfNoPendingDependencies(parentQueueKey, parentDependenciesKey, parentKey, parentId, timestamp)
- end
|