@@ -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 | |