protected function dequeueProcessesWithoutDelay(): void
    {
        $queuedProcesses = $this->processSet->get(ProcessWrapper::PROCESS_STATUS_QUEUED);

        foreach ($queuedProcesses as $className => $processWrapper) {
            if ($processWrapper->isDelayed()) {
                $this->io->writeln(
                    sprintf(
                        'Testcase "%s" is queued to be run %01.1f minutes after testcase "%s" is finished',
                        $className,
                        $processWrapper->getDelayMinutes(),
                        $processWrapper->getDelayAfter()
                    ),
                    OutputInterface::VERBOSITY_DEBUG
                );
            } elseif ($this->parallelLimitReached()) {
                $this->io->writeln(
                    sprintf('Max parallel limit reached, testcase "%s" is queued', $className),
                    OutputInterface::VERBOSITY_QUIET
                );
            } else {
                $this->io->writeln(
                    sprintf('Testcase "%s" is prepared to be run', $className),
                    OutputInterface::VERBOSITY_DEBUG
                );
                $processWrapper->setStatus(ProcessWrapper::PROCESS_STATUS_PREPARED);
            }
        }
    }
protected function dequeueProcessesWithoutDelay(): void
    {
        $queuedProcesses = $this->processSet->get(ProcessWrapper::PROCESS_STATUS_QUEUED);

        foreach ($queuedProcesses as $className => $processWrapper) {
            if ($processWrapper->isDelayed()) {
                $this->io->writeln(
                    sprintf(
                        'Testcase "%s" is queued to be run %01.1f minutes after testcase "%s" is finished',
                        $className,
                        $processWrapper->getDelayMinutes(),
                        $processWrapper->getDelayAfter()
                    ),
                    OutputInterface::VERBOSITY_DEBUG
                );
            } elseif ($this->parallelLimitReached()) {
                $this->io->writeln(
                    sprintf('Max parallel limit reached, testcase "%s" is queued', $className),
                    OutputInterface::VERBOSITY_QUIET
                );
            } else {
                $this->io->writeln(
                    sprintf('Testcase "%s" is prepared to be run', $className),
                    OutputInterface::VERBOSITY_DEBUG
                );
                $processWrapper->setStatus(ProcessWrapper::PROCESS_STATUS_PREPARED);
            }
        }
    }
protected function dequeueProcessesWithoutDelay ( ) : void { $ queuedProcesses = $ this -> processSet -> get ( ProcessWrapper :: PROCESS_STATUS_QUEUED ) ; foreach ( $ queuedProcesses as $ className => $ processWrapper ) { if ( $ processWrapper -> isDelayed ( ) ) { $ this -> io -> writeln ( sprintf ( 'Testcase "%s" is queued to be run %01.1f minutes after testcase "%s" is finished' , $ className , $ processWrapper -> getDelayMinutes ( ) , $ processWrapper -> getDelayAfter ( ) ) , OutputInterface :: VERBOSITY_DEBUG ) ; } elseif ( $ this -> parallelLimitReached ( ) ) { $ this -> io -> writeln ( sprintf ( 'Max parallel limit reached, testcase "%s" is queued' , $ className ) , OutputInterface :: VERBOSITY_QUIET ) ; } else { $ this -> io -> writeln ( sprintf ( 'Testcase "%s" is prepared to be run' , $ className ) , OutputInterface :: VERBOSITY_DEBUG ) ; $ processWrapper -> setStatus ( ProcessWrapper :: PROCESS_STATUS_PREPARED ) ; } } }
Set queued processes without delay as prepared
Set queued processes without delay as prepared