Move Share Migration code to Data Service
Removed functionality of Share Migration relying on Manila Share
Service node, moved code to Data Service node for copy phase.
Added parameter 'notify' and share/api methods for future
implementation (see dependent patches).
Added new copy operation statuses, in order to implement future
API calls to obtain progress and cancel migration.
Added possibility of 2-phase migration for driver migration and
generic (fallback) migration.
Added admin export location support and removed approach of
replacing IP with config parameter.
Added Admin-only API entry points to:
- Migration Cancel (only during copying)
- Reset Task State field
- Migration Get Progress (only during copying)
- Migration Complete (2nd phase migration)
- Notify parameter on Migrate Share
APIImpact
DocImpact
Implements: blueprint data-service-migration
Change-Id: I1d65aac2f36942cd70eb214be561d59a15a4ba26
diff --git a/manila_tempest_tests/tests/api/base.py b/manila_tempest_tests/tests/api/base.py
index 6236cad..0eae2ad 100644
--- a/manila_tempest_tests/tests/api/base.py
+++ b/manila_tempest_tests/tests/api/base.py
@@ -343,11 +343,22 @@
return share
@classmethod
- def migrate_share(cls, share_id, dest_host, client=None, **kwargs):
+ def migrate_share(cls, share_id, dest_host, client=None, notify=True,
+ wait_for_status='migration_success', **kwargs):
client = client or cls.shares_v2_client
- client.migrate_share(share_id, dest_host, **kwargs)
- share = client.wait_for_migration_completed(
- share_id, dest_host, version=kwargs.get('version'))
+ client.migrate_share(share_id, dest_host, notify, **kwargs)
+ share = client.wait_for_migration_status(
+ share_id, dest_host, wait_for_status,
+ version=kwargs.get('version'))
+ return share
+
+ @classmethod
+ def migration_complete(cls, share_id, dest_host, client=None, **kwargs):
+ client = client or cls.shares_v2_client
+ client.migration_complete(share_id, **kwargs)
+ share = client.wait_for_migration_status(
+ share_id, dest_host, 'migration_success',
+ version=kwargs.get('version'))
return share
@classmethod