From ce0853d099bfdb6d5a54baeecc34d10933f3e87e Mon Sep 17 00:00:00 2001 From: licanwei Date: Wed, 23 Jan 2019 15:26:52 +0800 Subject: [PATCH] Add create_volume for volume test Change-Id: I6fcbadc211416cc2c7b15bb15678cfed09e52008 --- .../tests/scenario/manager.py | 24 +++++++++++++++++++ 1 file changed, 24 insertions(+) diff --git a/watcher_tempest_plugin/tests/scenario/manager.py b/watcher_tempest_plugin/tests/scenario/manager.py index e6637b4..68e9332 100644 --- a/watcher_tempest_plugin/tests/scenario/manager.py +++ b/watcher_tempest_plugin/tests/scenario/manager.py @@ -198,3 +198,27 @@ class ScenarioTest(tempest.test.BaseTestCase): clients.servers_client.delete_server, body['id']) server = clients.servers_client.show_server(body['id'])['server'] return server + + def create_volume(self, name=None, image_id=None, size=None, + volume_type=None, clients=None): + + if clients is None: + clients = self.os_primary + + if name is None: + name = data_utils.rand_name(self.__class__.__name__ + "-volume") + volumes_client = clients.volumes_client_latest + params = {'name': name, + 'imageRef': image_id, + 'volume_type': volume_type, + 'size': size or CONF.volume.volume_size} + volume = volumes_client.create_volume(**params)['volume'] + self.addCleanup(volumes_client.wait_for_resource_deletion, + volume['id']) + self.addCleanup(test_utils.call_and_ignore_notfound_exc, + volumes_client.delete_volume, volume['id']) + self.assertEqual(name, volume['name']) + waiters.wait_for_volume_resource_status(volumes_client, + volume['id'], 'available') + volume = volumes_client.show_volume(volume['id'])['volume'] + return volume