|
4 | 4 |
|
5 | 5 | namespace SchedulerBundle\Command; |
6 | 6 |
|
| 7 | +use function array_pop; |
| 8 | + |
7 | 9 | use DateTimeImmutable; |
| 10 | + |
| 11 | +use function implode; |
| 12 | +use function in_array; |
| 13 | + |
8 | 14 | use Psr\Log\LoggerInterface; |
9 | 15 | use Psr\Log\NullLogger; |
| 16 | +use SchedulerBundle\Event\TaskExecutedEvent; |
10 | 17 | use SchedulerBundle\Event\WorkerSleepingEvent; |
| 18 | +use SchedulerBundle\EventListener\StopWorkerOnFailureLimitSubscriber; |
| 19 | +use SchedulerBundle\EventListener\StopWorkerOnTaskLimitSubscriber; |
| 20 | +use SchedulerBundle\EventListener\StopWorkerOnTimeLimitSubscriber; |
| 21 | +use SchedulerBundle\SchedulerInterface; |
| 22 | +use SchedulerBundle\Task\Output; |
11 | 23 | use SchedulerBundle\Task\ProbeTask; |
12 | 24 | use SchedulerBundle\Task\TaskInterface; |
13 | 25 | use SchedulerBundle\Worker\WorkerConfiguration; |
| 26 | +use SchedulerBundle\Worker\WorkerInterface; |
| 27 | + |
| 28 | +use function sprintf; |
| 29 | + |
14 | 30 | use Symfony\Component\Console\Attribute\AsCommand; |
15 | 31 | use Symfony\Component\Console\Command\Command; |
16 | 32 | use Symfony\Component\Console\Helper\Helper; |
17 | 33 | use Symfony\Component\Console\Input\InputInterface; |
18 | 34 | use Symfony\Component\Console\Input\InputOption; |
| 35 | + |
19 | 36 | use Symfony\Component\Console\Output\OutputInterface; |
20 | 37 | use Symfony\Component\Console\Style\SymfonyStyle; |
21 | | -use SchedulerBundle\Event\TaskExecutedEvent; |
22 | | -use SchedulerBundle\EventListener\StopWorkerOnFailureLimitSubscriber; |
23 | | -use SchedulerBundle\EventListener\StopWorkerOnTaskLimitSubscriber; |
24 | | -use SchedulerBundle\EventListener\StopWorkerOnTimeLimitSubscriber; |
25 | | -use SchedulerBundle\SchedulerInterface; |
26 | | -use SchedulerBundle\Task\Output; |
27 | | -use SchedulerBundle\Worker\WorkerInterface; |
28 | 38 | use Symfony\Component\EventDispatcher\EventDispatcherInterface; |
29 | 39 | use Throwable; |
30 | 40 |
|
31 | | -use function array_pop; |
32 | | -use function implode; |
33 | | -use function in_array; |
34 | | -use function sprintf; |
35 | | - |
36 | 41 | /** |
37 | 42 | * @author Guillaume Loulier <[email protected]> |
38 | 43 | */ |
@@ -123,7 +128,7 @@ protected function execute(InputInterface $input, OutputInterface $output): int |
123 | 128 | } |
124 | 129 |
|
125 | 130 | if (false === $force) { |
126 | | - $nonPausedTasks = $dueTasks->filter(static fn (TaskInterface $task): bool => $task->getState() !== TaskInterface::PAUSED); |
| 131 | + $nonPausedTasks = $dueTasks->filter(static fn (TaskInterface $task): bool => TaskInterface::PAUSED !== $task->getState()); |
127 | 132 | if (0 === $nonPausedTasks->count()) { |
128 | 133 | $symfonyStyle->warning([ |
129 | 134 | 'Each tasks has already been executed for the current minute', |
|
0 commit comments