@@ -288,7 +288,7 @@ |
||
288 | 288 | protected function collectJob(array $job, int $status, $from_status = JobInterface::STATUS_WAITING): bool |
289 | 289 | { |
290 | 290 | $set = [ |
291 | - 'status' => $status, |
|
291 | + 'status' => $status, |
|
292 | 292 | ]; |
293 | 293 | |
294 | 294 | if (JobInterface::STATUS_PROCESSING === $status) { |
@@ -190,7 +190,7 @@ discard block |
||
190 | 190 | break; |
191 | 191 | } |
192 | 192 | |
193 | - $this->jobs->next($cursor, function () { |
|
193 | + $this->jobs->next($cursor, function() { |
|
194 | 194 | $this->start(); |
195 | 195 | }); |
196 | 196 | |
@@ -198,7 +198,7 @@ discard block |
||
198 | 198 | } |
199 | 199 | |
200 | 200 | $job = $cursor->current(); |
201 | - $this->jobs->next($cursor, function () { |
|
201 | + $this->jobs->next($cursor, function() { |
|
202 | 202 | $this->start(); |
203 | 203 | }); |
204 | 204 |