Skip to content

Commit

Permalink
Cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
arjanwestdorp committed Feb 10, 2021
1 parent 00061a4 commit 4021ecd
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion src/Repositories/RedisWorkloadRepository.php
Original file line number Diff line number Diff line change
Expand Up @@ -72,7 +72,7 @@ public function get()
$totalProcesses = $processes[$queue] ?? 0;

$length = ! Str::contains($queue, ',')
? collect($this->queue->connection($connection)->readyNow($queueName))
? collect([$queueName => $this->queue->connection($connection)->readyNow($queueName)])
: collect(explode(',', $queueName))->mapWithKeys(function ($queueName) use ($connection) {
return [$queueName => $this->queue->connection($connection)->readyNow($queueName)];
});
Expand Down
4 changes: 2 additions & 2 deletions src/WaitTimeCalculator.php
Original file line number Diff line number Diff line change
Expand Up @@ -80,7 +80,7 @@ public function calculate($queue = null)
}

/**
* Calculate the time to clear for the given in queue in seconds distributed over the given amount of processes.
* Calculate the time to clear for the given queue in seconds distributed over the given amount of processes.
*
* @param string $connection
* @param string $queue
Expand Down Expand Up @@ -123,7 +123,7 @@ protected function queueNames($supervisors, $queue = null)
* @param string $queue
* @return float
*/
public function timeToClearFor($connection, $queue)
protected function timeToClearFor($connection, $queue)
{
$size = $this->queue->connection($connection)->readyNow($queue);

Expand Down

0 comments on commit 4021ecd

Please sign in to comment.