MCPcopy Create free account
hub / github.com/taskforcesh/bullmq / moveJobsToWait

Method moveJobsToWait

php/src/Scripts.php:482–490  ·  view source on GitHub ↗

* Move jobs to wait state (for retrying). * * @param string $state Source state * @param int $count Number of jobs to move * @param int $timestamp Timestamp filter * @return int Cursor position */

(string $state, int $count, int $timestamp)

Source from the content-addressed store, hash-verified

480 * @return int Cursor position
481 */
482 public function moveJobsToWait(string $state, int $count, int $timestamp): int
483 {
484 $keys = $this->getKeys(['', 'events', $state, 'wait', 'paused', 'meta', 'active', 'marker']);
485 $args = [$count, $timestamp, $state];
486
487 $result = $this->execScript('moveJobsToWait-8.lua', $keys, $args);
488
489 return (int) $result;
490 }
491
492 /**
493 * Remove a job.

Callers 2

retryJobsMethod · 0.80
promoteJobsMethod · 0.80

Calls 2

getKeysMethod · 0.95
execScriptMethod · 0.95

Tested by

no test coverage detected