Merge pull request #4446 from annando/worker-priority

Bugfix: The provided worker priority had been ignored

diff --git a/src/Core/Worker.php b/src/Core/Worker.php
index e8a1f2e9f61d997948adbd0a41b5299b924a1088..140d0e014d5f348aa7f910909bba5472639cc3e3 100644 (file)
--- a/src/Core/Worker.php
+++ b/src/Core/Worker.php
@@ -1018,6 +1018,8 @@ class Worker
                $dont_fork = Config::get("system", "worker_dont_fork");
                $created = DateTimeFormat::utcNow();
 
+               $run_parameter = array_shift($args);
+
                if (is_int($run_parameter)) {
                        $priority = $run_parameter;
                } elseif (is_array($run_parameter)) {
@@ -1032,8 +1034,6 @@ class Worker
                        }
                }
 
-               array_shift($args);
-
                $parameters = json_encode($args);
                $found = dba::exists('workerqueue', ['parameter' => $parameters, 'done' => false]);