markJobExecutionAsFailedWhenInterrupted = $markJobExecutionAsFailedWhenInterrupted; } protected function configure() { $this ->addArgument( 'jobCodes', InputArgument::REQUIRED, 'Job instance codes that need to have job executions to be cleaned. For example: "job_1,job_2".' ) ->setDescription( 'Mark as failed the job executions that are stuck in status STARTED or STOPPING.' ); } protected function execute(InputInterface $input, OutputInterface $output): int { $jobCodes = $input->getArgument('jobCodes'); $jobCodes = array_map('trim', explode(',', trim($jobCodes))); $impactedRows = $this->markJobExecutionAsFailedWhenInterrupted->execute($jobCodes); $output->writeln(sprintf('%s job executions cleaned', $impactedRows)); return 0; } }