@@ -92,7 +92,7 @@ |
||
92 | 92 | $this->eventDispatcher->dispatch(Event::PRE_JOB, $event); |
93 | 93 | |
94 | 94 | $start = microtime(true); |
95 | - $handleException = function ($exception) use ($job) { |
|
95 | + $handleException = function($exception) use ($job) { |
|
96 | 96 | /** @var \Exception $exception */ |
97 | 97 | $exceptionMessage = get_class($exception)."\n".$exception->getCode().' - '.$exception->getMessage()."\n".$exception->getTraceAsString(); |
98 | 98 | $this->log('debug', "Failed: {$job->getClassName()}->{$job->getMethod()}"); |
@@ -33,7 +33,7 @@ |
||
33 | 33 | $total += count($this->jobs[$jobWorkerName]); |
34 | 34 | } |
35 | 35 | |
36 | - return array_sum(array_map(function ($jobs) { return count($jobs); }, $this->jobs)); |
|
36 | + return array_sum(array_map(function($jobs) { return count($jobs); }, $this->jobs)); |
|
37 | 37 | } |
38 | 38 | |
39 | 39 | public function getStatus() |
@@ -3,7 +3,6 @@ |
||
3 | 3 | namespace Dtc\QueueBundle\Command; |
4 | 4 | |
5 | 5 | use Dtc\QueueBundle\Model\Job; |
6 | -use Dtc\QueueBundle\Model\Run; |
|
7 | 6 | use Dtc\QueueBundle\Run\Loop; |
8 | 7 | use Dtc\QueueBundle\Util\Util; |
9 | 8 | use Psr\Log\LoggerInterface; |