diff --git a/src/MigrateUpgradeDrushRunner.php b/src/MigrateUpgradeDrushRunner.php index f340e08..5935044 100644 --- a/src/MigrateUpgradeDrushRunner.php +++ b/src/MigrateUpgradeDrushRunner.php @@ -258,6 +258,14 @@ class MigrateUpgradeDrushRunner { else { $process['migration'] = $this->modifyId($process['migration']); } + if (isset($process['source_ids']) && is_array($process['source_ids'])) { + $new_source_ids = []; + foreach ($process['source_ids'] as $migration_id => $source_ids) { + $new_migration_id = $this->modifyId($migration_id); + $new_source_ids[$new_migration_id] = $source_ids; + } + $process['source_ids'] = $new_source_ids; + } } else { // Recurse on each array member.