Use the post language for the language detection / config for quality

[friendica.git] / src / Core / Worker.php

diff --git a/src/Core/Worker.php b/src/Core/Worker.php
index c84b59e2b7324c5ec6838c3962706e3f306c54c9..d7eaeb15ebcada0c2c8cd31bc2328661be03e609 100644 (file)
--- a/src/Core/Worker.php
+++ b/src/Core/Worker.php
@@ -1276,7 +1276,7 @@ class Worker
                $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;
                }
 
@@ -1379,10 +1379,11 @@ class Worker
        /**
         * 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();
 
@@ -1395,6 +1396,10 @@ class Worker
 
                $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) {