Merge "Add a call to management.validate(task)"
This commit is contained in:
commit
6b64010f46
@ -1175,6 +1175,7 @@ class ConductorManager(periodic_task.PeriodicTasks):
|
||||
try:
|
||||
with task_manager.acquire(context, node_uuid, shared=True) \
|
||||
as task:
|
||||
task.driver.management.validate(task)
|
||||
sensors_data = task.driver.management.get_sensors_data(
|
||||
task)
|
||||
except NotImplementedError:
|
||||
|
@ -1322,6 +1322,8 @@ class UpdatePortTestCase(_ServiceSetUpMixin, tests_db_base.DbTestCase):
|
||||
acquire_mock.return_value.__enter__.return_value.driver = self.driver
|
||||
with mock.patch.object(self.driver.management,
|
||||
'get_sensors_data') as get_sensors_data_mock:
|
||||
with mock.patch.object(self.driver.management,
|
||||
'validate') as validate_mock:
|
||||
get_sensors_data_mock.return_value = 'fake-sensor-data'
|
||||
_mapped_to_this_conductor_mock.return_value = True
|
||||
get_nodeinfo_list_mock.return_value = [(node.uuid, node.driver,
|
||||
@ -1331,6 +1333,7 @@ class UpdatePortTestCase(_ServiceSetUpMixin, tests_db_base.DbTestCase):
|
||||
self.assertTrue(_mapped_to_this_conductor_mock.called)
|
||||
self.assertTrue(acquire_mock.called)
|
||||
self.assertTrue(get_sensors_data_mock.called)
|
||||
self.assertTrue(validate_mock.called)
|
||||
|
||||
@mock.patch.object(manager.ConductorManager, '_mapped_to_this_conductor')
|
||||
@mock.patch.object(dbapi.IMPL, 'get_nodeinfo_list')
|
||||
@ -1343,6 +1346,8 @@ class UpdatePortTestCase(_ServiceSetUpMixin, tests_db_base.DbTestCase):
|
||||
acquire_mock.return_value.__enter__.return_value.driver = self.driver
|
||||
with mock.patch.object(self.driver.management,
|
||||
'get_sensors_data') as get_sensors_data_mock:
|
||||
with mock.patch.object(self.driver.management,
|
||||
'validate') as validate_mock:
|
||||
get_sensors_data_mock.return_value = 'fake-sensor-data'
|
||||
_mapped_to_this_conductor_mock.return_value = True
|
||||
get_nodeinfo_list_mock.return_value = [(node.uuid, node.driver,
|
||||
@ -1352,6 +1357,7 @@ class UpdatePortTestCase(_ServiceSetUpMixin, tests_db_base.DbTestCase):
|
||||
self.assertFalse(_mapped_to_this_conductor_mock.called)
|
||||
self.assertFalse(acquire_mock.called)
|
||||
self.assertFalse(get_sensors_data_mock.called)
|
||||
self.assertFalse(validate_mock.called)
|
||||
|
||||
def test_set_boot_device(self):
|
||||
node = obj_utils.create_test_node(self.context, driver='fake')
|
||||
|
Loading…
x
Reference in New Issue
Block a user