diff --git a/rally-jobs/cinder.yaml b/rally-jobs/cinder.yaml index e3ce28828b..dd21048fb3 100644 --- a/rally-jobs/cinder.yaml +++ b/rally-jobs/cinder.yaml @@ -477,6 +477,23 @@ sla: failure_rate: max: 0 + - + args: + size: 1 + runner: + type: "constant" + times: 1 + concurrency: 1 + context: + users: + tenants: 1 + users_per_tenant: 1 + api_versions: + glance: + version: 2 + sla: + failure_rate: + max: 0 CinderVolumes.create_volume_backup: - diff --git a/rally-jobs/nova.yaml b/rally-jobs/nova.yaml index a0b514e73a..ef50057f28 100644 --- a/rally-jobs/nova.yaml +++ b/rally-jobs/nova.yaml @@ -493,6 +493,26 @@ sla: failure_rate: max: 0 + - + args: + flavor: + name: "m1.tiny" + image: + name: {{image_name}} + runner: + type: "constant" + times: 2 + concurrency: 2 + context: + users: + tenants: 2 + users_per_tenant: 2 + api_versions: + glance: + version: 2 + sla: + failure_rate: + max: 0 NovaServers.boot_server: - diff --git a/rally/plugins/openstack/cleanup/resources.py b/rally/plugins/openstack/cleanup/resources.py index 036b13bb71..e02a3cd89e 100644 --- a/rally/plugins/openstack/cleanup/resources.py +++ b/rally/plugins/openstack/cleanup/resources.py @@ -15,6 +15,7 @@ from boto import exception as boto_exception from neutronclient.common import exceptions as neutron_exceptions +from oslo_config import cfg from saharaclient.api import base as saharaclient_base from rally.common import logging @@ -26,6 +27,9 @@ from rally.plugins.openstack.scenarios.keystone import utils as kutils from rally.plugins.openstack.scenarios.nova import utils as nova_utils from rally.plugins.openstack.wrappers import glance as glance_wrapper from rally.plugins.openstack.wrappers import keystone as keystone_wrapper +from rally.task import utils as task_utils + +CONF = cfg.CONF LOG = logging.getLogger(__name__) @@ -390,15 +394,24 @@ class ManilaSecurityService(base.ResourceManager): @base.resource("glance", "images", order=500, tenant_resource=True) class GlanceImage(base.ResourceManager): + def _client(self): + return getattr(self.admin or self.user, self._service) + def _wrapper(self): - return glance_wrapper.wrap( - getattr(self.admin or self.user, self._service), self) + return glance_wrapper.wrap(self._client(), self) def list(self): return self._wrapper().list_images(owner=self.tenant_uuid) def delete(self): - return self._wrapper().delete_image(self.raw_resource) + client = self._client() + client().images.delete(self.raw_resource.id) + task_utils.wait_for_status( + self.raw_resource, ["deleted"], + check_deletion=True, + update_resource=self._wrapper().get_image, + timeout=CONF.benchmark.glance_image_delete_timeout, + check_interval=CONF.benchmark.glance_image_delete_poll_interval) # SAHARA diff --git a/rally/plugins/openstack/context/glance/images.py b/rally/plugins/openstack/context/glance/images.py index b11fad32e6..7731c79a0b 100644 --- a/rally/plugins/openstack/context/glance/images.py +++ b/rally/plugins/openstack/context/glance/images.py @@ -12,6 +12,8 @@ # License for the specific language governing permissions and limitations # under the License. +from oslo_config import cfg + from rally.common.i18n import _ from rally.common import logging from rally.common import utils as rutils @@ -19,7 +21,9 @@ from rally import consts from rally import osclients from rally.plugins.openstack.wrappers import glance as glance_wrapper from rally.task import context +from rally.task import utils +CONF = cfg.CONF LOG = logging.getLogger(__name__) @@ -117,4 +121,11 @@ class ImageGenerator(context.Context): api_info=self.context["config"].get("api_versions")) glance_wrap = glance_wrapper.wrap(clients.glance, self) for image in self.context["tenants"][tenant_id].get("images", []): - glance_wrap.delete_image(clients.glance().images.get(image)) + clients.glance().images.delete(image) + utils.wait_for_status( + clients.glance().images.get(image), ["deleted"], + check_deletion=True, + update_resource=glance_wrap.get_image, + timeout=CONF.benchmark.glance_image_delete_timeout, + check_interval=CONF.benchmark. + glance_image_delete_poll_interval) diff --git a/rally/plugins/openstack/scenarios/cinder/utils.py b/rally/plugins/openstack/scenarios/cinder/utils.py index 4d48a064b7..78e5dc2f30 100644 --- a/rally/plugins/openstack/scenarios/cinder/utils.py +++ b/rally/plugins/openstack/scenarios/cinder/utils.py @@ -21,6 +21,7 @@ from oslo_config import cfg from rally import exceptions from rally.plugins.openstack import scenario from rally.plugins.openstack.wrappers import cinder as cinder_wrapper +from rally.plugins.openstack.wrappers import glance as glance_wrapper from rally.task import atomic from rally.task import utils as bench_utils @@ -233,10 +234,11 @@ class CinderScenario(scenario.OpenStackScenario): ) image_id = img["os-volume_upload_image"]["image_id"] image = self.clients("glance").images.get(image_id) + wrapper = glance_wrapper.wrap(self._clients.glance, self) image = bench_utils.wait_for( image, ready_statuses=["active"], - update_resource=bench_utils.get_from_manager(), + update_resource=wrapper.get_image, timeout=CONF.benchmark.glance_image_create_timeout, check_interval=CONF.benchmark.glance_image_create_poll_interval ) diff --git a/rally/plugins/openstack/scenarios/glance/utils.py b/rally/plugins/openstack/scenarios/glance/utils.py index 7380a7dd8b..24ff1036f3 100644 --- a/rally/plugins/openstack/scenarios/glance/utils.py +++ b/rally/plugins/openstack/scenarios/glance/utils.py @@ -13,9 +13,26 @@ # License for the specific language governing permissions and limitations # under the License. +from oslo_config import cfg + from rally.plugins.openstack import scenario from rally.plugins.openstack.wrappers import glance as glance_wrapper from rally.task import atomic +from rally.task import utils + +GLANCE_BENCHMARK_OPTS = [ + cfg.FloatOpt("glance_image_delete_timeout", + default=120.0, + help="Time to wait for glance image to be deleted."), + cfg.FloatOpt("glance_image_delete_poll_interval", + default=1.0, + help="Interval between checks when waiting for image " + "deletion.") +] + +CONF = cfg.CONF +benchmark_group = cfg.OptGroup(name="benchmark", title="benchmark options") +CONF.register_opts(GLANCE_BENCHMARK_OPTS, group=benchmark_group) class GlanceScenario(scenario.OpenStackScenario): @@ -54,5 +71,11 @@ class GlanceScenario(scenario.OpenStackScenario): :param image: Image object """ - client = glance_wrapper.wrap(self._clients.glance, self) - client.delete_image(image) + self.clients("glance").images.delete(image.id) + wrapper = glance_wrapper.wrap(self._clients.glance, self) + utils.wait_for_status( + image, ["deleted"], + check_deletion=True, + update_resource=wrapper.get_image, + timeout=CONF.benchmark.glance_image_delete_timeout, + check_interval=CONF.benchmark.glance_image_delete_poll_interval) diff --git a/rally/plugins/openstack/scenarios/nova/utils.py b/rally/plugins/openstack/scenarios/nova/utils.py index 6e53f94729..53ab75144f 100644 --- a/rally/plugins/openstack/scenarios/nova/utils.py +++ b/rally/plugins/openstack/scenarios/nova/utils.py @@ -21,6 +21,7 @@ import six from rally import exceptions from rally.plugins.openstack import scenario +from rally.plugins.openstack.wrappers import glance as glance_wrapper from rally.plugins.openstack.wrappers import network as network_wrapper from rally.task import atomic from rally.task import utils @@ -464,13 +465,14 @@ class NovaScenario(scenario.OpenStackScenario): :param image: Image object """ - image.delete() + self.clients("glance").images.delete(image.id) + wrapper = glance_wrapper.wrap(self._clients.glance, self) check_interval = CONF.benchmark.nova_server_image_delete_poll_interval utils.wait_for_status( image, ready_statuses=["deleted"], check_deletion=True, - update_resource=utils.get_from_manager(), + update_resource=wrapper.get_image, timeout=CONF.benchmark.nova_server_image_delete_timeout, check_interval=check_interval ) diff --git a/rally/plugins/openstack/wrappers/glance.py b/rally/plugins/openstack/wrappers/glance.py index 244d336924..26eb0d615d 100644 --- a/rally/plugins/openstack/wrappers/glance.py +++ b/rally/plugins/openstack/wrappers/glance.py @@ -39,14 +39,7 @@ GLANCE_BENCHMARK_OPTS = [ cfg.FloatOpt("glance_image_create_poll_interval", default=1.0, help="Interval between checks when waiting for image " - "creation."), - cfg.FloatOpt("glance_image_delete_timeout", - default=120.0, - help="Time to wait for glance image to be deleted."), - cfg.FloatOpt("glance_image_delete_poll_interval", - default=1.0, - help="Interval between checks when waiting for image " - "deletion.") + "creation.") ] CONF = cfg.CONF @@ -60,6 +53,24 @@ class GlanceWrapper(object): self.owner = owner self.client = client + def get_image(self, image): + """Gets image. + + This serves to fetch the latest data on the image for the + various wait_for_*() functions. + + Must raise rally.exceptions.GetResourceNotFound if the + resource is not found or deleted. + """ + # NOTE(stpierre): This function actually has a single + # implementation that works for both Glance v1 and Glance v2, + # but since we need to use this function in both wrappers, it + # gets implemented here. + try: + return self.client.images.get(image.id) + except glance_exc.HTTPNotFound: + raise exceptions.GetResourceNotFound(resource=image) + @abc.abstractmethod def create_image(self, container_format, image_location, disk_format): """Creates new image. @@ -67,10 +78,6 @@ class GlanceWrapper(object): Accepts all Glance v2 parameters. """ - @abc.abstractmethod - def delete_image(self, image): - """Deletes image.""" - @abc.abstractmethod def list_images(self, **filters): """List images. @@ -106,7 +113,7 @@ class GlanceV1Wrapper(GlanceWrapper): image = utils.wait_for_status( image, ["active"], - update_resource=utils.get_from_manager(), + update_resource=self.get_image, timeout=CONF.benchmark.glance_image_create_timeout, check_interval=CONF.benchmark. glance_image_create_poll_interval) @@ -116,15 +123,6 @@ class GlanceV1Wrapper(GlanceWrapper): return image - def delete_image(self, image): - image.delete() - utils.wait_for_status( - image, ["deleted"], - check_deletion=True, - update_resource=utils.get_from_manager(), - timeout=CONF.benchmark.glance_image_delete_timeout, - check_interval=CONF.benchmark.glance_image_delete_poll_interval) - def list_images(self, **filters): kwargs = {"filters": filters} if "owner" in filters: @@ -142,12 +140,6 @@ class GlanceV1Wrapper(GlanceWrapper): class GlanceV2Wrapper(GlanceWrapper): - def _update_image(self, image): - try: - return self.client.images.get(image.id) - except glance_exc.HTTPNotFound: - raise exceptions.GetResourceNotFound(resource=image) - def create_image(self, container_format, image_location, disk_format, **kwargs): kw = { @@ -167,7 +159,7 @@ class GlanceV2Wrapper(GlanceWrapper): start = time.time() image = utils.wait_for_status( image, ["queued"], - update_resource=self._update_image, + update_resource=self.get_image, timeout=CONF.benchmark.glance_image_create_timeout, check_interval=CONF.benchmark. glance_image_create_poll_interval) @@ -190,20 +182,11 @@ class GlanceV2Wrapper(GlanceWrapper): return utils.wait_for_status( image, ["active"], - update_resource=self._update_image, + update_resource=self.get_image, timeout=timeout, check_interval=CONF.benchmark. glance_image_create_poll_interval) - def delete_image(self, image): - self.client.images.delete(image.id) - utils.wait_for_status( - image, ["deleted"], - check_deletion=True, - update_resource=self._update_image, - timeout=CONF.benchmark.glance_image_delete_timeout, - check_interval=CONF.benchmark.glance_image_delete_poll_interval) - def list_images(self, **filters): return self.client.images.list(filters=filters) diff --git a/rally/verification/tempest/config.py b/rally/verification/tempest/config.py index dec305fae1..d0d318437d 100644 --- a/rally/verification/tempest/config.py +++ b/rally/verification/tempest/config.py @@ -32,8 +32,9 @@ from rally.common import objects from rally.common import utils from rally import exceptions from rally import osclients -from rally.plugins.openstack.wrappers import glance as glance_wrapper +from rally.plugins.openstack.wrappers import glance from rally.plugins.openstack.wrappers import network +from rally.task import utils as task_utils LOG = logging.getLogger(__name__) @@ -419,14 +420,14 @@ class TempestResourcesContext(utils.RandomNameGeneratorMixin): .format(opt=option, opt_val=option_value)) def _discover_or_create_image(self): - glance_wrap = glance_wrapper.wrap(self.clients.glance, self) + glance_wrapper = glance.wrap(self.clients.glance, self) if CONF.image.name_regex: LOG.debug("Trying to discover a public image with name matching " "regular expression '%s'. Note that case insensitive " "matching is performed" % CONF.image.name_regex) - images = glance_wrap.list_images(status="active", - visibility="public") + images = glance_wrapper.list_images(status="active", + visibility="public") for img in images: if img.name and re.match(CONF.image.name_regex, img.name, re.IGNORECASE): @@ -447,7 +448,7 @@ class TempestResourcesContext(utils.RandomNameGeneratorMixin): "visibility": "public" } LOG.debug("Creating image '%s'" % params["name"]) - image = glance_wrap.create_image(**params) + image = glance_wrapper.create_image(**params) self._created_images.append(image) return image @@ -498,10 +499,17 @@ class TempestResourcesContext(utils.RandomNameGeneratorMixin): keystoneclient.roles.delete(role.id) def _cleanup_images(self): - glanceclient = self.clients.glance() + glance_wrapper = glance.wrap(self.clients.glance, self) for image in self._created_images: LOG.debug("Deleting image '%s'" % image.name) - glanceclient.images.delete(image.id) + self.clients.glance().images.delete(image.id) + task_utils.wait_for_status( + image, ["deleted"], + check_deletion=True, + update_resource=glance_wrapper.get_image, + timeout=CONF.benchmark.glance_image_delete_timeout, + check_interval=CONF.benchmark. + glance_image_delete_poll_interval) self._remove_opt_value_from_config("compute", image.id) def _cleanup_flavors(self): diff --git a/tests/unit/plugins/openstack/cleanup/test_resources.py b/tests/unit/plugins/openstack/cleanup/test_resources.py index 90069c3a7d..3bd5056a00 100644 --- a/tests/unit/plugins/openstack/cleanup/test_resources.py +++ b/tests/unit/plugins/openstack/cleanup/test_resources.py @@ -462,14 +462,18 @@ class GlanceImageTestCase(test.TestCase): def test_delete(self): glance = resources.GlanceImage() + glance._client = mock.Mock() glance._wrapper = mock.Mock() glance.raw_resource = mock.Mock() - self.assertEqual( - glance.delete(), - glance._wrapper.return_value.delete_image.return_value) - glance._wrapper.return_value.delete_image.assert_called_once_with( - glance.raw_resource) + client = glance._client.return_value + wrapper = glance._wrapper.return_value + + deleted_image = mock.Mock(status="DELETED") + wrapper.get_image.side_effect = [glance.raw_resource, deleted_image] + + glance.delete() + client().images.delete.assert_called_once_with(glance.raw_resource.id) class CeilometerTestCase(test.TestCase): diff --git a/tests/unit/plugins/openstack/context/glance/test_images.py b/tests/unit/plugins/openstack/context/glance/test_images.py index 5b547333fd..3acdc7bdb9 100644 --- a/tests/unit/plugins/openstack/context/glance/test_images.py +++ b/tests/unit/plugins/openstack/context/glance/test_images.py @@ -185,16 +185,17 @@ class ImageGeneratorTestCase(test.ScenarioTestCase): images_ctx = images.ImageGenerator(self.context) images_ctx.cleanup() - glance_client = mock_clients.return_value.glance.return_value - glance_client.images.get.assert_has_calls([mock.call(i) - for i in created_images]) wrapper_calls = [] wrapper_calls.extend([mock.call(mock_clients.return_value.glance, images_ctx)] * tenants_count) - wrapper_calls.extend( - [mock.call().delete_image(glance_client.images.get.return_value)] * - len(created_images)) mock_wrap.assert_has_calls(wrapper_calls, any_order=True) + + glance_client = mock_clients.return_value.glance.return_value + glance_client.images.delete.assert_has_calls([mock.call(i) + for i in created_images]) + glance_client.images.get.assert_has_calls([mock.call(i) + for i in created_images]) + mock_clients.assert_has_calls( [mock.call(mock.ANY, api_info=api_versions)] * tenants_count, any_order=True) diff --git a/tests/unit/plugins/openstack/scenarios/cinder/test_utils.py b/tests/unit/plugins/openstack/scenarios/cinder/test_utils.py index 1d33583ea5..550c57afdb 100644 --- a/tests/unit/plugins/openstack/scenarios/cinder/test_utils.py +++ b/tests/unit/plugins/openstack/scenarios/cinder/test_utils.py @@ -196,7 +196,8 @@ class CinderScenarioTestCase(test.ScenarioTestCase): self._test_atomic_action_timer(self.scenario.atomic_actions(), "cinder.extend_volume") - def test__upload_volume_to_image(self): + @mock.patch("rally.plugins.openstack.wrappers.glance.wrap") + def test__upload_volume_to_image(self, mock_wrap): volume = mock.Mock() image = {"os-volume_upload_image": {"image_id": 1}} volume.upload_to_image.return_value = (None, image) @@ -220,13 +221,12 @@ class CinderScenarioTestCase(test.ScenarioTestCase): mock.call( self.clients("glance").images.get.return_value, ready_statuses=["active"], - update_resource=self.mock_get_from_manager.mock.return_value, + update_resource=mock_wrap.return_value.get_image, timeout=CONF.benchmark.glance_image_create_timeout, check_interval=CONF.benchmark. glance_image_create_poll_interval) ]) - self.mock_get_from_manager.mock.assert_has_calls([mock.call(), - mock.call()]) + self.mock_get_from_manager.mock.assert_called_once_with() self.clients("glance").images.get.assert_called_once_with(1) def test__create_snapshot(self): diff --git a/tests/unit/plugins/openstack/scenarios/glance/test_utils.py b/tests/unit/plugins/openstack/scenarios/glance/test_utils.py index 13ebcf5586..8824386e57 100644 --- a/tests/unit/plugins/openstack/scenarios/glance/test_utils.py +++ b/tests/unit/plugins/openstack/scenarios/glance/test_utils.py @@ -75,10 +75,16 @@ class GlanceScenarioTestCase(test.ScenarioTestCase): @mock.patch("rally.plugins.openstack.wrappers.glance.wrap") def test_delete_image(self, mock_wrap): + deleted_image = mock.Mock(status="DELETED") + wrapper = mock_wrap.return_value + wrapper.get_image.side_effect = [self.image, deleted_image] + scenario = utils.GlanceScenario(context=self.context, clients=self.scenario_clients) scenario._delete_image(self.image) + self.clients("glance").images.delete.assert_called_once_with( + self.image.id) + mock_wrap.assert_called_once_with(scenario._clients.glance, scenario) - mock_wrap.return_value.delete_image.assert_called_once_with(self.image) self._test_atomic_action_timer(scenario.atomic_actions(), "glance.delete_image") diff --git a/tests/unit/plugins/openstack/scenarios/nova/test_utils.py b/tests/unit/plugins/openstack/scenarios/nova/test_utils.py index 71b400cbf9..35ef41bca8 100644 --- a/tests/unit/plugins/openstack/scenarios/nova/test_utils.py +++ b/tests/unit/plugins/openstack/scenarios/nova/test_utils.py @@ -407,19 +407,21 @@ class NovaScenarioTestCase(test.ScenarioTestCase): def test__force_delete_servers(self): self._test_delete_servers(force=True) - def test__delete_image(self): + @mock.patch("rally.plugins.openstack.wrappers.glance.wrap") + def test__delete_image(self, mock_wrap): nova_scenario = utils.NovaScenario(context=self.context) + nova_scenario._clients = mock.Mock() nova_scenario._delete_image(self.image) - self.image.delete.assert_called_once_with() + self.clients("glance").images.delete.assert_called_once_with( + self.image.id) self.mock_wait_for_status.mock.assert_called_once_with( self.image, ready_statuses=["deleted"], check_deletion=True, - update_resource=self.mock_get_from_manager.mock.return_value, + update_resource=mock_wrap.return_value.get_image, check_interval=CONF.benchmark. nova_server_image_delete_poll_interval, timeout=CONF.benchmark.nova_server_image_delete_timeout) - self.mock_get_from_manager.mock.assert_called_once_with() self._test_atomic_action_timer(nova_scenario.atomic_actions(), "nova.delete_image") diff --git a/tests/unit/plugins/openstack/wrappers/test_glance.py b/tests/unit/plugins/openstack/wrappers/test_glance.py index 30bbb86d2c..39221863fb 100644 --- a/tests/unit/plugins/openstack/wrappers/test_glance.py +++ b/tests/unit/plugins/openstack/wrappers/test_glance.py @@ -61,6 +61,24 @@ class GlanceV1WrapperTestCase(test.ScenarioTestCase): self.owner = mock.Mock() self.wrapped_client = glance_wrapper.wrap(self.client, self.owner) + def test_get_image(self): + image = mock.Mock() + + return_image = self.wrapped_client.get_image(image) + + self.client.return_value.images.get.assert_called_once_with(image.id) + self.assertEqual(return_image, + self.client.return_value.images.get.return_value) + + def test_get_image_not_found(self): + image = mock.Mock() + self.client.return_value.images.get.side_effect = ( + glance_exc.HTTPNotFound) + + self.assertRaises(exceptions.GetResourceNotFound, + self.wrapped_client.get_image, image) + self.client.return_value.images.get.assert_called_once_with(image.id) + @ddt.data( {"location": "image_location", "visibility": "private"}, {"location": "image_location", "fakearg": "fake"}, @@ -91,25 +109,12 @@ class GlanceV1WrapperTestCase(test.ScenarioTestCase): self.mock_wait_for_status.mock.assert_called_once_with( self.client().images.create.return_value, ["active"], - update_resource=self.mock_get_from_manager.mock.return_value, + update_resource=self.wrapped_client.get_image, check_interval=CONF.benchmark.glance_image_create_poll_interval, timeout=CONF.benchmark.glance_image_create_timeout) - self.mock_get_from_manager.mock.assert_called_once_with() self.assertEqual(self.mock_wait_for_status.mock.return_value, return_image) - def test_delete_image(self): - image = mock.Mock() - self.wrapped_client.delete_image(image) - image.delete.assert_called_once_with() - self.mock_wait_for_status.mock.assert_called_once_with( - image, ["deleted"], - check_deletion=True, - update_resource=self.mock_get_from_manager.mock.return_value, - check_interval=CONF.benchmark.glance_image_delete_poll_interval, - timeout=CONF.benchmark.glance_image_delete_timeout) - self.mock_get_from_manager.mock.assert_called_once_with() - @ddt.data({}, {"fakearg": "fake"}) def test_list_images_basic(self, filters): self.assertEqual(self.wrapped_client.list_images(**filters), @@ -157,22 +162,22 @@ class GlanceV2WrapperTestCase(test.ScenarioTestCase): self.owner = mock.Mock() self.wrapped_client = glance_wrapper.wrap(self.client, self.owner) - def test__update_image(self): + def test_get_image(self): image = mock.Mock() - return_image = self.wrapped_client._update_image(image) + return_image = self.wrapped_client.get_image(image) self.client.return_value.images.get.assert_called_once_with(image.id) self.assertEqual(return_image, self.client.return_value.images.get.return_value) - def test__update_image_not_found(self): + def test_get_image_not_found(self): image = mock.Mock() self.client.return_value.images.get.side_effect = ( glance_exc.HTTPNotFound) self.assertRaises(exceptions.GetResourceNotFound, - self.wrapped_client._update_image, image) + self.wrapped_client.get_image, image) self.client.return_value.images.get.assert_called_once_with(image.id) @ddt.data( @@ -185,7 +190,7 @@ class GlanceV2WrapperTestCase(test.ScenarioTestCase): @mock.patch("requests.get") def test_create_image(self, mock_requests_get, mock_open, location, **kwargs): - self.wrapped_client._update_image = mock.Mock() + self.wrapped_client.get_image = mock.Mock() created_image = mock.Mock() uploaded_image = mock.Mock() self.mock_wait_for_status.mock.side_effect = [created_image, @@ -216,30 +221,18 @@ class GlanceV2WrapperTestCase(test.ScenarioTestCase): self.mock_wait_for_status.mock.assert_has_calls([ mock.call( self.client().images.create.return_value, ["queued"], - update_resource=self.wrapped_client._update_image, + update_resource=self.wrapped_client.get_image, check_interval=CONF.benchmark. glance_image_create_poll_interval, timeout=CONF.benchmark.glance_image_create_timeout), mock.call( created_image, ["active"], - update_resource=self.wrapped_client._update_image, + update_resource=self.wrapped_client.get_image, check_interval=CONF.benchmark. glance_image_create_poll_interval, timeout=mock.ANY)]) self.assertEqual(uploaded_image, return_image) - def test_delete_image(self): - image = mock.Mock() - self.wrapped_client.delete_image(image) - self.client.return_value.images.delete.assert_called_once_with( - image.id) - self.mock_wait_for_status.mock.assert_called_once_with( - image, ["deleted"], - check_deletion=True, - update_resource=self.wrapped_client._update_image, - check_interval=CONF.benchmark.glance_image_delete_poll_interval, - timeout=CONF.benchmark.glance_image_delete_timeout) - @ddt.data({}, {"fakearg": "fake"}) def test_list_images(self, filters): self.assertEqual(self.wrapped_client.list_images(**filters), diff --git a/tests/unit/verification/test_config.py b/tests/unit/verification/test_config.py index d2e9af2266..7e193baeed 100644 --- a/tests/unit/verification/test_config.py +++ b/tests/unit/verification/test_config.py @@ -472,16 +472,24 @@ class TempestResourcesContextTestCase(test.TestCase): client = self.context.clients.keystone() self.assertEqual(client.roles.delete.call_count, 2) - def test__cleanup_images(self): + @mock.patch("rally.plugins.openstack.wrappers.glance.wrap") + def test__cleanup_images(self, mock_wrap): self.context._created_images = [fakes.FakeImage(id="id1"), fakes.FakeImage(id="id2")] self.context.conf.set("compute", "image_ref", "id1") self.context.conf.set("compute", "image_ref_alt", "id2") + wrapper = mock_wrap.return_value + wrapper.get_image.side_effect = [ + fakes.FakeImage(id="id1", status="DELETED"), + fakes.FakeImage(id="id2"), + fakes.FakeImage(id="id2", status="DELETED")] + self.context._cleanup_images() client = self.context.clients.glance() - self.assertEqual(client.images.delete.call_count, 2) + client.images.delete.assert_has_calls([mock.call("id1"), + mock.call("id2")]) self.assertEqual("", self.context.conf.get("compute", "image_ref")) self.assertEqual("", self.context.conf.get("compute", "image_ref_alt"))