mmucklo / DtcQueueBundle

            ->addOption('older', null, InputOption::VALUE_REQUIRED, self::OLDER_MESSAGE);

    }

    protected function execute(InputInterface $input, OutputInterface $output)

    {

        $container = $this->getContainer();

        $jobManager = $container->get('dtc_queue.job_manager');

        $type = $input->getArgument('type');

        switch ($type) {

            case 'error':

                $count = $jobManager->pruneErroneousJobs();

                $output->writeln("$count Erroneous Job(s) pruned");

                break;

            case 'expired':

                $count = $jobManager->pruneExpiredJobs();

                $output->writeln("$count Expired Job(s) pruned");

                break;

            default:

                return $this->executeStalledOther($input, $output);

        }

        return 0;

    }

    public function executeStalledOther(InputInterface $input, OutputInterface $output)

    {

        return 0;

    }

    public function executeStalledOther(InputInterface $input, OutputInterface $output)

    {

        $container = $this->getContainer();

        $jobManager = $container->get('dtc_queue.job_manager');

        $type = $input->getArgument('type');

        switch ($type) {

            case 'stalled':

                $count = $jobManager->pruneStalledJobs();

                $output->writeln("$count Stalled Job(s) pruned");

                break;

            case 'stalled_runs':

                $count = $container->get('dtc_queue.run_manager')->pruneStalledRuns();

                $output->writeln("$count Stalled Job(s) pruned");

                break;

            default:

                return $this->executeOlder($input, $output);

        }

        return 0;

    }

    public function executeOlder(InputInterface $input, OutputInterface $output)

    {