src/Process/ExecutionLoop.php
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