@@ -68,7 +68,7 @@ |
||
68 | 68 | set_time_limit($processTimeout); // Set an hour timeout |
69 | 69 | |
70 | 70 | if ($jobId = $input->getOption('job_id')) { |
71 | - return $this->runJobById($jobId); // Run a single job |
|
71 | + return $this->runJobById($jobId); // Run a single job |
|
72 | 72 | } |
73 | 73 | |
74 | 74 | try { |
@@ -63,7 +63,7 @@ discard block |
||
63 | 63 | $this->logger->debug('No job to run'); |
64 | 64 | } |
65 | 65 | |
66 | - return; // no job to run |
|
66 | + return; // no job to run |
|
67 | 67 | } |
68 | 68 | |
69 | 69 | return $this->runJob($job); |
@@ -75,7 +75,7 @@ discard block |
||
75 | 75 | $this->eventDispatcher->dispatch(Event::PRE_JOB, $event); |
76 | 76 | |
77 | 77 | $start = microtime(true); |
78 | - $handleException = function ($exception) use ($job) { |
|
78 | + $handleException = function($exception) use ($job) { |
|
79 | 79 | $exceptionMessage = get_class($exception)."\n".$exception->getCode().' - '.$exception->getMessage()."\n".$exception->getTraceAsString(); |
80 | 80 | if ($this->logger) { |
81 | 81 | $this->logger->debug("Failed: {$job->getClassName()}->{$job->getMethod()}\n$exceptionMessage"); |
@@ -86,7 +86,7 @@ |
||
86 | 86 | { |
87 | 87 | $start = microtime(true); |
88 | 88 | $jobsTotal = 1000; |
89 | - self::$jobManager->enableSorting = false; // Ignore priority |
|
89 | + self::$jobManager->enableSorting = false; // Ignore priority |
|
90 | 90 | |
91 | 91 | for ($i = 0; $i < $jobsTotal; ++$i) { |
92 | 92 | self::$worker->later()->fibonacci(1); |