protected function flush(TaskConfiguration $taskConfiguration): void
    {
        $task = $taskConfiguration->getTask();
        if ($task instanceof BlockingTaskInterface) {
            return;
        }
        if ($task instanceof FlushableTaskInterface) {
            $this->process($taskConfiguration, self::EXECUTE_FLUSH);
            if ($taskConfiguration->getState()->isStopped()) {
                return;
            }
        }
        // Check outputs
        foreach ($taskConfiguration->getNextTasksConfigurations() as $nextTaskConfiguration) {
            $this->flush($nextTaskConfiguration);
        }
        // Check errors
        foreach ($taskConfiguration->getErrorTasksConfigurations() as $errorTasksConfiguration) {
            $this->flush($errorTasksConfiguration);
        }
    }
protected function flush(TaskConfiguration $taskConfiguration): void
    {
        $task = $taskConfiguration->getTask();
        if ($task instanceof BlockingTaskInterface) {
            return;
        }
        if ($task instanceof FlushableTaskInterface) {
            $this->process($taskConfiguration, self::EXECUTE_FLUSH);
            if ($taskConfiguration->getState()->isStopped()) {
                return;
            }
        }
        // Check outputs
        foreach ($taskConfiguration->getNextTasksConfigurations() as $nextTaskConfiguration) {
            $this->flush($nextTaskConfiguration);
        }
        // Check errors
        foreach ($taskConfiguration->getErrorTasksConfigurations() as $errorTasksConfiguration) {
            $this->flush($errorTasksConfiguration);
        }
    }
protected function flush ( TaskConfiguration $ taskConfiguration ) : void { $ task = $ taskConfiguration -> getTask ( ) ; if ( $ task instanceof BlockingTaskInterface ) { return ; } if ( $ task instanceof FlushableTaskInterface ) { $ this -> process ( $ taskConfiguration , self :: EXECUTE_FLUSH ) ; if ( $ taskConfiguration -> getState ( ) -> isStopped ( ) ) { return ; } } // Check outputs foreach ( $ taskConfiguration -> getNextTasksConfigurations ( ) as $ nextTaskConfiguration ) { $ this -> flush ( $ nextTaskConfiguration ) ; } // Check errors foreach ( $ taskConfiguration -> getErrorTasksConfigurations ( ) as $ errorTasksConfiguration ) { $ this -> flush ( $ errorTasksConfiguration ) ; } }
Browse all children for FlushableTask until a BlockingTask is found

@param TaskConfiguration $taskConfiguration

@throws \RuntimeException
Browse all children for FlushableTask until a BlockingTask is found