@@ -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. |
@@ -159,7 +159,7 @@ discard block |
||
159 | 159 | { |
160 | 160 | $driverName = $this->_getDriverName(); |
161 | 161 | $options = [ |
162 | - 'fields' => function (Query $query) use ($driverName) { |
|
162 | + 'fields' => function(Query $query) use ($driverName) { |
|
163 | 163 | $alltime = $query->func()->avg('UNIX_TIMESTAMP(completed) - UNIX_TIMESTAMP(created)'); |
164 | 164 | $runtime = $query->func()->avg('UNIX_TIMESTAMP(completed) - UNIX_TIMESTAMP(fetched)'); |
165 | 165 | $fetchdelay = $query->func()->avg('UNIX_TIMESTAMP(fetched) - IF(not_before is NULL, UNIX_TIMESTAMP(created), UNIX_TIMESTAMP(not_before))'); |
@@ -207,7 +207,7 @@ discard block |
||
207 | 207 | public function getFullStats($taskName = null) |
208 | 208 | { |
209 | 209 | $driverName = $this->_getDriverName(); |
210 | - $fields = function (Query $query) use ($driverName) { |
|
210 | + $fields = function(Query $query) use ($driverName) { |
|
211 | 211 | $runtime = $query->newExpr('UNIX_TIMESTAMP(completed) - UNIX_TIMESTAMP(fetched)'); |
212 | 212 | switch ($driverName) { |
213 | 213 | case static::DRIVER_SQLSERVER: |
@@ -342,7 +342,7 @@ discard block |
||
342 | 342 | debug($query); |
343 | 343 | debug($options); |
344 | 344 | /** @var \Queue\Model\Entity\QueuedTask|null $task */ |
345 | - $task = $this->getConnection()->transactional(function () use ($query, $options, $now) { |
|
345 | + $task = $this->getConnection()->transactional(function() use ($query, $options, $now) { |
|
346 | 346 | $task = $query->find('all', $options) |
347 | 347 | ->enableAutoFields(true) |
348 | 348 | ->epilog('FOR UPDATE') |