$added = 0;
if (!is_int($priority) || !in_array($priority, self::PRIORITIES)) {
- Logger::warning('Invalid priority', ['priority' => $priority, 'command' => $command, 'callstack' => System::callstack(20)]);
+ Logger::warning('Invalid priority', ['priority' => $priority, 'command' => $command]);
$priority = self::PRIORITY_MEDIUM;
}
/**
* Defers the current worker entry
*
+ * @param int $worker_defer_limit Maximum defer limit
* @return boolean had the entry been deferred?
* @throws \Exception
*/
- public static function defer(): bool
+ public static function defer(int $worker_defer_limit = 0): bool
{
$queue = DI::app()->getQueue();
$max_level = DI::config()->get('system', 'worker_defer_limit');
+ if ($worker_defer_limit) {
+ $max_level = min($worker_defer_limit, $max_level);
+ }
+
$new_retrial = self::getNextRetrial($queue, $max_level);
if ($new_retrial > $max_level) {