updateParentDepsIfNeeded.lua 484 B

12345678910111213
  1. --[[
  2. Validate and move or add dependencies to parent.
  3. ]]
  4. -- Includes
  5. --- @include "moveParentToWaitIfNoPendingDependencies"
  6. local function updateParentDepsIfNeeded(parentKey, parentQueueKey, parentDependenciesKey,
  7. parentId, jobIdKey, returnvalue, timestamp )
  8. local processedSet = parentKey .. ":processed"
  9. rcall("HSET", processedSet, jobIdKey, returnvalue)
  10. moveParentToWaitIfNoPendingDependencies(parentQueueKey, parentDependenciesKey, parentKey, parentId, timestamp)
  11. end