setName('autogedal:feed-monitor:allow-incomplete') ->setDescription('Feed monitor: the next run of a job may update from a feed smaller than the threshold') ->addArgument('job', InputArgument::REQUIRED, 'Job code, e.g. alfaromtrans_paravanturi_stock') ->addOption('feed', null, InputOption::VALUE_REQUIRED, 'Sub-feed code, for jobs with sub-feeds'); } protected function execute(InputInterface $input, OutputInterface $output): int { $jobCode = (string)$input->getArgument('job'); $feedCode = (string)$input->getOption('feed'); if (!$this->jobs->has($jobCode)) { $output->writeln('Job necunoscut. Joburi urmarite: ' . implode(', ', $this->jobs->getJobCodes()) . ''); return Cli::RETURN_FAILURE; } $feeds = $this->jobs->getFeedCodes($jobCode); if ($feeds && !in_array($feedCode, $feeds, true)) { $output->writeln('Jobul are sub-feed-uri, alege unul cu --feed: ' . implode(', ', $feeds) . ''); return Cli::RETURN_FAILURE; } if (!$feeds && $feedCode !== '') { $output->writeln('Jobul nu are sub-feed-uri, ruleaza fara --feed.'); return Cli::RETURN_FAILURE; } $this->states->allowIncomplete(MonitorKey::build($jobCode, $feedCode)); $output->writeln(sprintf( 'Urmatoarea rulare a %s va actualiza chiar daca feed-ul este sub prag (o singura data, valabil %d ore).', $this->jobs->getLabel($jobCode, $feedCode), StateRepository::ALLOWANCE_HOURS )); return Cli::RETURN_SUCCESS; } }