diff --git a/api/environments/dynamodb/migrator.py b/api/environments/dynamodb/migrator.py index d53763c20160..975b4c192921 100644 --- a/api/environments/dynamodb/migrator.py +++ b/api/environments/dynamodb/migrator.py @@ -6,6 +6,7 @@ from features.models import FeatureState from features.multivariate.models import MultivariateFeatureStateValue from projects.models import Project +from projects.tasks import migrate_project_environments_to_v2 from util.queryset import iterator_with_prefetch from .types import DynamoProjectMetadata, ProjectIdentityMigrationStatus @@ -81,4 +82,5 @@ def migrate(self): ) ) identity_wrapper.write_identities(iterator_with_prefetch(identities)) + migrate_project_environments_to_v2(project_id) self.project_metadata.finish_identity_migration()