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