Merge branch 'workload-per-queue' of https://github.com/arjanwestdorp…

…/horizon into workload-per-queue
laravel · Feb 14, 2021 · 4cb7adf · 4cb7adf
2 parents b4e8c6a + 96b177d
commit 4cb7adf
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/Repositories/RedisWorkloadRepository.php b/src/Repositories/RedisWorkloadRepository.php
@@ -78,11 +78,11 @@ public function get()
                         return [$queueName => $this->queue->connection($connection)->readyNow($queueName)];
                     });
 
-                $splitQueues = Str::contains($queue, ',') ? $length->map(function ($length, $queueName) use ($connection, $totalProcesses) {
+                $splitQueues = Str::contains($queue, ',') ? $length->map(function ($length, $queueName) use ($connection, $totalProcesses, &$wait) {
                     return [
                         'name' => $queueName,
                         'length' => $length,
-                        'wait' => $this->waitTime->calculateTimeToClear($connection, $queueName, $totalProcesses),
+                        'wait' => $wait += $this->waitTime->calculateTimeToClear($connection, $queueName, $totalProcesses),
                     ];
                 }) : null;