@@ -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() |
@@ -46,6 +46,9 @@ discard block |
||
46 | 46 | $this->failureTest($time, 'later'); |
47 | 47 | } |
48 | 48 | |
49 | + /** |
|
50 | + * @param string $method |
|
51 | + */ |
|
49 | 52 | public function batchLaterTest($method) |
50 | 53 | { |
51 | 54 | $time = null; |
@@ -65,6 +68,9 @@ discard block |
||
65 | 68 | $this->failureTest($time, 'batchLater'); |
66 | 69 | } |
67 | 70 | |
71 | + /** |
|
72 | + * @param string $time |
|
73 | + */ |
|
68 | 74 | protected function failureTest($method, $time) |
69 | 75 | { |
70 | 76 | // Test job with object |