@@ -132,7 +132,7 @@ |
||
| 132 | 132 | |
| 133 | 133 | // if foreground, we redirect output |
| 134 | 134 | if ($input->getOption('foreground')) { |
| 135 | - $process->run(function ($type, $buffer) use ($output) { |
|
| 135 | + $process->run(function($type, $buffer) use ($output) { |
|
| 136 | 136 | $output->write($buffer); |
| 137 | 137 | }); |
| 138 | 138 | } // else we recompose and display the worker id |
@@ -106,7 +106,7 @@ |
||
| 106 | 106 | $output->writeln(\sprintf('Starting worker <info>%s</info>', $process->getCommandLine())); |
| 107 | 107 | |
| 108 | 108 | if ($input->getOption('foreground')) { |
| 109 | - $process->run(function ($type, $buffer) use ($output) { |
|
| 109 | + $process->run(function($type, $buffer) use ($output) { |
|
| 110 | 110 | $output->write($buffer); |
| 111 | 111 | }); |
| 112 | 112 | } // else we recompose and display the worker id |
@@ -251,7 +251,7 @@ |
||
| 251 | 251 | */ |
| 252 | 252 | public function getRunningWorkers() |
| 253 | 253 | { |
| 254 | - return array_filter($this->getWorkers(), function (Worker $worker) { |
|
| 254 | + return array_filter($this->getWorkers(), function(Worker $worker) { |
|
| 255 | 255 | return $worker->getCurrentJob() !== null; |
| 256 | 256 | }); |
| 257 | 257 | } |
@@ -174,7 +174,7 @@ discard block |
||
| 174 | 174 | { |
| 175 | 175 | $count = $this->getResque()->retryFailedJobs(); |
| 176 | 176 | |
| 177 | - $this->addFlash('info', 'Retry '.$count.' failed jobs.'); |
|
| 177 | + $this->addFlash('info', 'Retry ' . $count . ' failed jobs.'); |
|
| 178 | 178 | |
| 179 | 179 | return $this->redirectToRoute('ResqueBundle_homepage'); |
| 180 | 180 | } |
@@ -186,7 +186,7 @@ discard block |
||
| 186 | 186 | { |
| 187 | 187 | $count = $this->getResque()->retryFailedJobs(true); |
| 188 | 188 | |
| 189 | - $this->addFlash('info', 'Retry and clear '.$count.' failed jobs.'); |
|
| 189 | + $this->addFlash('info', 'Retry and clear ' . $count . ' failed jobs.'); |
|
| 190 | 190 | |
| 191 | 191 | return $this->redirectToRoute('ResqueBundle_homepage'); |
| 192 | 192 | } |
@@ -198,7 +198,7 @@ discard block |
||
| 198 | 198 | { |
| 199 | 199 | $count = $this->getResque()->clearFailedJobs(); |
| 200 | 200 | |
| 201 | - $this->addFlash('info', 'Clear '.$count.' failed jobs.'); |
|
| 201 | + $this->addFlash('info', 'Clear ' . $count . ' failed jobs.'); |
|
| 202 | 202 | |
| 203 | 203 | return $this->redirectToRoute('ResqueBundle_homepage'); |
| 204 | 204 | } |