Loading migrate_scheduler.module +7 −0 Original line number Diff line number Diff line <?php /** * @file * Contains implementation of cron function to execute scheduled migrations. Loading Loading @@ -45,6 +46,12 @@ function migrate_scheduler_cron() { } $executable = new MigrateExecutable($migration, new MigrateMessage()); $executable->import(); // If using migrate_plus module, update the migrate_last_imported value for the migration. $moduleHandler = \Drupal::service('module_handler'); if ($moduleHandler->moduleExists('migrate_plus')) { $migrate_last_imported_store = \Drupal::keyValue('migrate_last_imported'); $migrate_last_imported_store->set($migration->id(), round(\Drupal::time()->getCurrentMicroTime() * 1000)); } } } } Loading Loading
migrate_scheduler.module +7 −0 Original line number Diff line number Diff line <?php /** * @file * Contains implementation of cron function to execute scheduled migrations. Loading Loading @@ -45,6 +46,12 @@ function migrate_scheduler_cron() { } $executable = new MigrateExecutable($migration, new MigrateMessage()); $executable->import(); // If using migrate_plus module, update the migrate_last_imported value for the migration. $moduleHandler = \Drupal::service('module_handler'); if ($moduleHandler->moduleExists('migrate_plus')) { $migrate_last_imported_store = \Drupal::keyValue('migrate_last_imported'); $migrate_last_imported_store->set($migration->id(), round(\Drupal::time()->getCurrentMicroTime() * 1000)); } } } } Loading