Incoviba/oficial
1
0
Fork 0
Code Issues Pull Requests 2 Releases Wiki Activity

Wait till next minute after running jobs

Browse Source
This commit is contained in:
Juan Pablo Vial
2025-05-13 15:53:13 -04:00
parent c47d94d475
commit e7f3b33850
1 changed files with 9 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
cli/src/Command/BaseLoop.php
View File

@ -28,24 +28,27 @@ class BaseLoop extends Console\Command\Command
$this->write($output, 'Starting loop...'); $this->write($output, 'Starting loop...');
while (true) { while (true) {
$commands = $this->scheduleService->getPending(); $commands = $this->scheduleService->getPending();
$start = new DateTimeImmutable();
foreach ($commands as $command) { foreach ($commands as $command) {
$this->runCommand($input, $output, $command); $this->runCommand($input, $output, $command);
sleep(10);
} }
$this->waitNextMinute($output, $start);
} }
return self::SUCCESS; return self::SUCCESS;
} }
protected function waitNextMinute(Console\Output\OutputInterface $output): void protected function waitNextMinute(Console\Output\OutputInterface $output, ?DateTimeInterface $start = null): void
{ {
// wait for next minute // wait for next minute
$now = new DateTimeImmutable(); if ($start === null) {
$nextMinute = new DateTimeImmutable($now->format('Y-m-d H:i:00')); $start = new DateTimeImmutable();
}
$nextMinute = new DateTimeImmutable($start->format('Y-m-d H:i:00'));
$nextMinute = $nextMinute->add(new \DateInterval('PT1M')); $nextMinute = $nextMinute->add(new \DateInterval('PT1M'));
$this->logger->debug('Wait', [ $this->logger->debug('Wait', [
'now' => $now->format('Y-m-d H:i:s.u'), 'start' => $start->format('Y-m-d H:i:s.u'),
'nextMinute' => $nextMinute->format('Y-m-d H:i:s.u'), 'nextMinute' => $nextMinute->format('Y-m-d H:i:s.u'),
]); ]);
$diff = $nextMinute->getTimestamp() - $now->getTimestamp(); $diff = $nextMinute->getTimestamp() - $start->getTimestamp();
if ($diff > 0) { if ($diff > 0) {
$output->writeln("Waiting {$diff} seconds..."); $output->writeln("Waiting {$diff} seconds...");
sleep($diff); sleep($diff);