openstack
/
rally
Code Issues Proposed changes

Add id_attr to use in wait_for_status method 

This patch set adds id_attr to define name of id field
when resource is being updated.

Change-Id: Ia6644e02aecc38df76e8c1b1cf3de9f8358096ec
This commit is contained in:
Alexander Chadin 2016-07-12 14:26:06 +03:00
parent 8dba332c52
commit ea6a01c94a
2 changed files with 40 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
rally/task/utils.py
View File

@ -70,10 +70,10 @@ def get_from_manager(error_statuses=None):
error_statuses = error_statuses or ["ERROR"]
error_statuses = map(lambda str: str.upper(), error_statuses)
def _get_from_manager(resource):
def _get_from_manager(resource, id_attr="id"):
# catch client side errors
try:
res = resource.manager.get(resource.id)
res = resource.manager.get(getattr(resource, id_attr))
except Exception as e:
if getattr(e, "code", getattr(e, "http_status", 400)) == 404:
raise exceptions.GetResourceNotFound(resource=resource)
@ -103,7 +103,7 @@ def manager_list_size(sizes):
@logging.log_deprecated("Use wait_for_status instead.", "0.1.2", once=True)
def wait_for(resource, is_ready=None, ready_statuses=None,
failure_statuses=None, status_attr="status", update_resource=None,
timeout=60, check_interval=1):
timeout=60, check_interval=1, id_attr="id"):
"""Waits for the given resource to come into the one of the given statuses.
The method can be used to check resource for status with a `is_ready`
@ -144,7 +144,8 @@ def wait_for(resource, is_ready=None, ready_statuses=None,
status_attr=status_attr,
update_resource=update_resource,
timeout=timeout,
check_interval=check_interval)
check_interval=check_interval,
id_attr=id_attr)
@logging.log_deprecated("Use wait_for_status instead.", "0.1.2", once=True)
@ -173,7 +174,8 @@ def wait_is_ready(resource, is_ready, update_resource=None,
def wait_for_status(resource, ready_statuses, failure_statuses=None,
status_attr="status", update_resource=None,
timeout=60, check_interval=1, check_deletion=False):
timeout=60, check_interval=1, check_deletion=False,
id_attr="id"):
resource_repr = getattr(resource, "name", repr(resource))
if not isinstance(ready_statuses, (set, list, tuple)):
@ -208,7 +210,10 @@ def wait_for_status(resource, ready_statuses, failure_statuses=None,
while True:
try:
resource = update_resource(resource)
if id_attr == "id":
resource = update_resource(resource)
else:
resource = update_resource(resource, id_attr=id_attr)
except exceptions.GetResourceNotFound:
if check_deletion:
return

29
tests/unit/task/test_utils.py
View File

@ -86,6 +86,13 @@ class BenchmarkUtilsTestCase(test.TestCase):
manager._cache(resource)
self.assertEqual(get_from_manager(resource), resource)
def test_get_from_manager_with_uuid_field(self):
get_from_manager = utils.get_from_manager()
manager = fakes.FakeManager()
resource = fakes.FakeResource(manager=manager)
manager._cache(resource)
self.assertEqual(get_from_manager(resource, id_attr="uuid"), resource)
def test_get_from_manager_in_error_state(self):
get_from_manager = utils.get_from_manager()
manager = fakes.FakeManager()
@ -449,6 +456,28 @@ class WaitForStatusTestCase(test.TestCase):
mock.call({"status": "still_not_ready"}),
mock.call({"status": "almost_ready"})])
@mock.patch("rally.task.utils.time.sleep")
@mock.patch("rally.task.utils.time.time", return_value=1)
def test_wait_successful_with_uuid(self, mock_time, mock_sleep):
res = {"status": "not_ready"}
upd = mock.MagicMock(side_effect=[{"status": "not_ready"},
{"status": "not_ready_yet"},
{"status": "still_not_ready"},
{"status": "almost_ready"},
{"status": "ready"}])
utils.wait_for(resource=res, ready_statuses=["ready"],
update_resource=upd, id_attr="uuid")
upd.assert_has_calls([mock.call({"status": "not_ready"},
id_attr="uuid"),
mock.call({"status": "not_ready"},
id_attr="uuid"),
mock.call({"status": "not_ready_yet"},
id_attr="uuid"),
mock.call({"status": "still_not_ready"},
id_attr="uuid"),
mock.call({"status": "almost_ready"},
id_attr="uuid")])
@mock.patch("rally.task.utils.time.sleep")
@mock.patch("rally.task.utils.time.time", return_value=1)
def test_wait_failure(self, mock_time, mock_sleep):