@@ -17,7 +17,7 @@ discard block |
||
17 | 17 | use Queue\Shell\Task\QueueTaskInterface; |
18 | 18 | use RuntimeException; |
19 | 19 | use Throwable; |
20 | -declare(ticks = 1); |
|
20 | +declare(ticks=1); |
|
21 | 21 | |
22 | 22 | /** |
23 | 23 | * Main shell to init and run queue workers. |
@@ -354,7 +354,7 @@ discard block |
||
354 | 354 | public function getOptionParser() |
355 | 355 | { |
356 | 356 | $subcommandParser = [ |
357 | - 'options' => [ /* |
|
357 | + 'options' => [/* |
|
358 | 358 | * 'dry-run'=> array( |
359 | 359 | * 'short' => 'd', |
360 | 360 | * 'help' => 'Dry run the update, no jobs will actually be added.', |
@@ -189,7 +189,7 @@ discard block |
||
189 | 189 | { |
190 | 190 | $driverName = $this->_getDriverName(); |
191 | 191 | $options = [ |
192 | - 'fields' => function (Query $query) use ($driverName) { |
|
192 | + 'fields' => function(Query $query) use ($driverName) { |
|
193 | 193 | $alltime = $query->func()->avg('UNIX_TIMESTAMP(completed) - UNIX_TIMESTAMP(created)'); |
194 | 194 | $runtime = $query->func()->avg('UNIX_TIMESTAMP(completed) - UNIX_TIMESTAMP(fetched)'); |
195 | 195 | $fetchdelay = $query->func()->avg('UNIX_TIMESTAMP(fetched) - IF(not_before is NULL, UNIX_TIMESTAMP(created), UNIX_TIMESTAMP(not_before))'); |
@@ -236,7 +236,7 @@ discard block |
||
236 | 236 | public function getFullStats($taskName = null) |
237 | 237 | { |
238 | 238 | $driverName = $this->_getDriverName(); |
239 | - $fields = function (Query $query) use ($driverName) { |
|
239 | + $fields = function(Query $query) use ($driverName) { |
|
240 | 240 | $runtime = $query->newExpr('UNIX_TIMESTAMP(completed) - UNIX_TIMESTAMP(fetched)'); |
241 | 241 | switch ($driverName) { |
242 | 242 | case static::DRIVER_SQLSERVER: |
@@ -370,7 +370,7 @@ discard block |
||
370 | 370 | } |
371 | 371 | |
372 | 372 | /** @var \Queue\Model\Entity\QueuedTask|null $task */ |
373 | - $task = $this->getConnection()->transactional(function () use ($query, $options, $now) { |
|
373 | + $task = $this->getConnection()->transactional(function() use ($query, $options, $now) { |
|
374 | 374 | $task = $query->find('all', $options) |
375 | 375 | ->enableAutoFields(true) |
376 | 376 | ->epilog('FOR UPDATE') |