.../src/Plugin/migrate/process/MigrationLookup.php | 19 ++++++++++--------- 1 file changed, 10 insertions(+), 9 deletions(-) diff --git a/core/modules/migrate/src/Plugin/migrate/process/MigrationLookup.php b/core/modules/migrate/src/Plugin/migrate/process/MigrationLookup.php index 83f4659816..bc9865df4c 100644 --- a/core/modules/migrate/src/Plugin/migrate/process/MigrationLookup.php +++ b/core/modules/migrate/src/Plugin/migrate/process/MigrationLookup.php @@ -230,15 +230,16 @@ public function transform($value, MigrateExecutableInterface $migrate_executable $stub_migration = reset($lookup_migration_ids); } - $exists_in_source = (bool) \Drupal::service('plugin.manager.migration')->createInstance($stub_migration) - ->getSourcePlugin() - ->query() - ->condition($this->configuration['source'], $value[0]) - ->countQuery() - ->execute() - ->fetchField(); - if (!$exists_in_source) { - return $value; + $source_plugin = \Drupal::service('plugin.manager.migration')->createInstance($stub_migration)->getSourcePlugin(); + if (method_exists($source_plugin, 'query')) { + $exists_in_source = (bool) $source_plugin->query() + ->condition($this->configuration['source'], $value[0]) + ->countQuery() + ->execute() + ->fetchField(); + if (!$exists_in_source) { + return $value; + } } // Rethrow any exception as a MigrateException so the executable can shut