Recurring.php 1.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849
  1. <?php
  2. /**
  3. * Copyright © Magento, Inc. All rights reserved.
  4. * See COPYING.txt for license details.
  5. */
  6. declare(strict_types=1);
  7. namespace Magento\Cron\Setup;
  8. use Magento\Framework\Setup\InstallSchemaInterface;
  9. use Magento\Framework\Setup\ModuleContextInterface;
  10. use Magento\Framework\Setup\SchemaSetupInterface;
  11. /**
  12. * Cron recurring setup
  13. */
  14. class Recurring implements InstallSchemaInterface
  15. {
  16. /**
  17. * @var \Magento\Cron\Model\ResourceModel\Schedule
  18. */
  19. private $schedule;
  20. /**
  21. * Recurring constructor.
  22. * @param \Magento\Cron\Model\ResourceModel\Schedule $schedule
  23. */
  24. public function __construct(
  25. \Magento\Cron\Model\ResourceModel\Schedule $schedule
  26. ) {
  27. $this->schedule = $schedule;
  28. }
  29. /**
  30. * {@inheritdoc}
  31. */
  32. public function install(SchemaSetupInterface $setup, ModuleContextInterface $context)
  33. {
  34. $connection = $this->schedule->getConnection();
  35. $connection->update(
  36. $this->schedule->getMainTable(),
  37. [
  38. 'status' => \Magento\Cron\Model\Schedule::STATUS_ERROR,
  39. 'messages' => 'The job is terminated due to system upgrade'
  40. ],
  41. $connection->quoteInto('status = ?', \Magento\Cron\Model\Schedule::STATUS_RUNNING)
  42. );
  43. }
  44. }