@@ -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 |
@@ -149,7 +149,7 @@ discard block |
||
149 | 149 | { |
150 | 150 | $count = $this->getResque()->retryFailedJobs(); |
151 | 151 | |
152 | - $this->addFlash('info', 'Retry '.$count.' failed jobs.'); |
|
152 | + $this->addFlash('info', 'Retry ' . $count . ' failed jobs.'); |
|
153 | 153 | |
154 | 154 | return $this->redirectToRoute('ResqueBundle_homepage'); |
155 | 155 | } |
@@ -161,7 +161,7 @@ discard block |
||
161 | 161 | { |
162 | 162 | $count = $this->getResque()->clearFailedJobs(); |
163 | 163 | |
164 | - $this->addFlash('info', 'Clear '.$count.' failed jobs.'); |
|
164 | + $this->addFlash('info', 'Clear ' . $count . ' failed jobs.'); |
|
165 | 165 | |
166 | 166 | return $this->redirectToRoute('ResqueBundle_homepage'); |
167 | 167 | } |
@@ -168,7 +168,7 @@ discard block |
||
168 | 168 | } |
169 | 169 | |
170 | 170 | /** |
171 | - * @return RedirectResponse |
|
171 | + * @return \Symfony\Component\HttpFoundation\RedirectResponse |
|
172 | 172 | */ |
173 | 173 | public function retryFailedAction() |
174 | 174 | { |
@@ -180,7 +180,7 @@ discard block |
||
180 | 180 | } |
181 | 181 | |
182 | 182 | /** |
183 | - * @return RedirectResponse |
|
183 | + * @return \Symfony\Component\HttpFoundation\RedirectResponse |
|
184 | 184 | */ |
185 | 185 | public function clearFailedAction() |
186 | 186 | { |
@@ -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 | } |