diff --git a/src/Model/Table/QueueProcessesTable.php b/src/Model/Table/QueueProcessesTable.php index 49f2c0b8..bfb500d3 100644 --- a/src/Model/Table/QueueProcessesTable.php +++ b/src/Model/Table/QueueProcessesTable.php @@ -242,13 +242,13 @@ public function status(): array { ->enableHydration(false) ->all() ->toArray(); - /** @var array $results */ if (!$results) { return []; } $count = count($results); + /** @var array{modified: \Cake\I18n\DateTime} $record */ $record = array_shift($results); /** @var \Cake\I18n\DateTime $time */ $time = $record['modified']; diff --git a/src/Queue/Task/ProgressExampleTask.php b/src/Queue/Task/ProgressExampleTask.php index a1e59f9b..81ab7cea 100644 --- a/src/Queue/Task/ProgressExampleTask.php +++ b/src/Queue/Task/ProgressExampleTask.php @@ -75,7 +75,7 @@ public function description(): ?string { public function run(array $data, int $jobId): void { $this->io->hr(); $this->io->out('CakePHP Queue ProgressExample task.'); - $seconds = empty($data['duration']) ? 2 * static::MINUTE : (int)$data['duration']; + $seconds = !empty($data['duration']) ? (int)$data['duration'] : 2 * static::MINUTE; $this->io->out('A total of ' . $seconds . ' seconds need to pass...'); for ($i = 0; $i < $seconds; $i++) {