@@ -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') |
@@ -18,7 +18,7 @@ |
||
| 18 | 18 | use RuntimeException; |
| 19 | 19 | use Throwable; |
| 20 | 20 | |
| 21 | -declare(ticks = 1); |
|
| 21 | +declare(ticks=1); |
|
| 22 | 22 | |
| 23 | 23 | /** |
| 24 | 24 | * Main shell to init and run queue workers. |