summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSylvain Bauza <sbauza@redhat.com>2017-07-06 17:17:31 +0200
committerTony Breeds <tony@bakeyournoodle.com>2017-11-16 14:00:41 +1100
commit6ce8bcab7cd73e27adfd26fceee7ec7c397bfa9b (patch)
tree61ccf6113061d8a2140f48ff4947d82ea2487962
parente51043b873c14711d43c3e770149a32160a1ac1b (diff)
downloadnova-6ce8bcab7cd73e27adfd26fceee7ec7c397bfa9b.tar.gz
Pass requested_destination in filter_properties
When we added the requested_destination field for the RequestSpec object in Newton, we forgot to pass it to the legacy dictionary when wanting to use scheduler methods not yet supporting the NovaObject. As a consequence, when we were transforming the RequestSpec object into a tuple of (request_spec, filter_props) dicts and then rehydrating a new RequestSpec object using those dicts, the newly created object was not keeping that requested_destination field from the original. Conflicts: nova/objects/request_spec.py NOTE(mriedem): The conflict is due to not having change b26ef568077f1bd9af8076c362bad06da3ec7e43 in Newton. Conflicts: nova/tests/unit/objects/test_request_spec.py NOTE(tonyb): Due to having Icb418f2be575bb2ba82756fdeb67b24a28950746 Depends-On: I344d8fdded9b7d5385fcb41b699f1352acb4cda7 Change-Id: Iba0b88172e9a3bfd4f216dd364d70f7e01c60ee2 Closes-Bug: #1702454 (cherry picked from commit 69bef428bd555bb31f43db6ca9c21db8aeb9007e) (cherry picked from commit bceb176fb00104fb0e39d6f1f3183f616c2b90f7) (cherry picked from commit 841121a95d76b10e6738156b55ee8ebc648054b4)
-rw-r--r--nova/objects/request_spec.py7
-rw-r--r--nova/tests/functional/regressions/test_bug_1702454.py4
-rw-r--r--nova/tests/unit/objects/test_request_spec.py19
3 files changed, 25 insertions, 5 deletions
diff --git a/nova/objects/request_spec.py b/nova/objects/request_spec.py
index 3c9c9441fa..99fcea6a3b 100644
--- a/nova/objects/request_spec.py
+++ b/nova/objects/request_spec.py
@@ -247,6 +247,8 @@ class RequestSpec(base.NovaObject):
spec._populate_group_info(filter_properties)
scheduler_hints = filter_properties.get('scheduler_hints', {})
spec._from_hints(scheduler_hints)
+ spec.requested_destination = filter_properties.get(
+ 'requested_destination')
# NOTE(sbauza): Default the other fields that are not part of the
# original contract
@@ -355,6 +357,9 @@ class RequestSpec(base.NovaObject):
# we had to hydrate the field by putting a single item into a list.
filt_props['scheduler_hints'] = {hint: self.get_scheduler_hint(
hint) for hint in self.scheduler_hints}
+ if self.obj_attr_is_set('requested_destination'
+ ) and self.requested_destination:
+ filt_props['requested_destination'] = self.requested_destination
return filt_props
@classmethod
@@ -396,6 +401,8 @@ class RequestSpec(base.NovaObject):
spec_obj._from_limits(filter_properties.get('limits', {}))
spec_obj._from_hints(filter_properties.get('scheduler_hints', {}))
spec_obj.availability_zone = availability_zone
+ spec_obj.requested_destination = filter_properties.get(
+ 'requested_destination')
# NOTE(sbauza): Default the other fields that are not part of the
# original contract
diff --git a/nova/tests/functional/regressions/test_bug_1702454.py b/nova/tests/functional/regressions/test_bug_1702454.py
index 4216c0c643..c7307f0131 100644
--- a/nova/tests/functional/regressions/test_bug_1702454.py
+++ b/nova/tests/functional/regressions/test_bug_1702454.py
@@ -151,5 +151,5 @@ class SchedulerOnlyChecksTargetTest(test.TestCase,
self._wait_for_state_change(self.api, server, 'ACTIVE')
server = self.admin_api.get_server(server_id)
- # Unfortunately, the requested host isn't respected.
- self.assertEqual('host3', server['OS-EXT-SRV-ATTR:host'])
+ # Yeepee, that works!
+ self.assertEqual('host2', server['OS-EXT-SRV-ATTR:host'])
diff --git a/nova/tests/unit/objects/test_request_spec.py b/nova/tests/unit/objects/test_request_spec.py
index 8e6c819831..040bcce764 100644
--- a/nova/tests/unit/objects/test_request_spec.py
+++ b/nova/tests/unit/objects/test_request_spec.py
@@ -298,13 +298,22 @@ class _TestRequestSpecObject(object):
# just making sure that the context is set by the method
self.assertEqual(ctxt, spec._context)
+ def test_from_primitives_with_requested_destination(self):
+ destination = objects.Destination(host='foo')
+ spec_dict = {}
+ filt_props = {'requested_destination': destination}
+ ctxt = context.RequestContext('fake', 'fake')
+ spec = objects.RequestSpec.from_primitives(ctxt, spec_dict, filt_props)
+ self.assertEqual(destination, spec.requested_destination)
+
def test_from_components(self):
ctxt = context.RequestContext('fake-user', 'fake-project')
+ destination = objects.Destination(host='foo')
instance = fake_instance.fake_instance_obj(ctxt)
image = {'id': uuids.image_id, 'properties': {'mappings': []},
'status': 'fake-status', 'location': 'far-away'}
flavor = fake_flavor.fake_flavor_obj(ctxt)
- filter_properties = {}
+ filter_properties = {'requested_destination': destination}
instance_group = None
spec = objects.RequestSpec.from_components(ctxt, instance.uuid, image,
@@ -316,6 +325,7 @@ class _TestRequestSpecObject(object):
'Field: %s is not set' % field)
# just making sure that the context is set by the method
self.assertEqual(ctxt, spec._context)
+ self.assertEqual(destination, spec.requested_destination)
@mock.patch('nova.objects.RequestSpec._populate_group_info')
def test_from_components_with_instance_group(self, mock_pgi):
@@ -417,6 +427,7 @@ class _TestRequestSpecObject(object):
fake_computes_obj = objects.ComputeNodeList(
objects=[objects.ComputeNode(host='fake1',
hypervisor_hostname='node1')])
+ fake_dest = objects.Destination(host='fakehost')
spec = objects.RequestSpec(
ignore_hosts=['ignoredhost'],
force_hosts=['fakehost'],
@@ -430,7 +441,8 @@ class _TestRequestSpecObject(object):
instance_group=objects.InstanceGroup(hosts=['fake1'],
policies=['affinity'],
members=['inst1', 'inst2']),
- scheduler_hints={'foo': ['bar']})
+ scheduler_hints={'foo': ['bar']},
+ requested_destination=fake_dest)
expected = {'ignore_hosts': ['ignoredhost'],
'force_hosts': ['fakehost'],
'force_nodes': ['fakenode'],
@@ -444,7 +456,8 @@ class _TestRequestSpecObject(object):
'group_hosts': set(['fake1']),
'group_policies': set(['affinity']),
'group_members': set(['inst1', 'inst2']),
- 'scheduler_hints': {'foo': 'bar'}}
+ 'scheduler_hints': {'foo': 'bar'},
+ 'requested_destination': fake_dest}
self.assertEqual(expected, spec.to_legacy_filter_properties_dict())
def test_to_legacy_filter_properties_dict_with_nullable_values(self):