Merge "Fix servicing clean-up"

ironic/common/states.py

@@ -252,6 +252,11 @@ SERVICEHOLD = 'service hold'
 """ Node is being held for direct intervention from a service step. """
 
 
+"""All Node states related to servicing."""
+SERVICING_STATES = frozenset((SERVICING, SERVICEWAIT,
+                              SERVICEFAIL, SERVICEHOLD))
+
+
 # NOTE(kaifeng): INSPECTING is allowed to keep backwards compatibility,
 # starting from API 1.39 node update is disallowed in this state.
 UPDATE_ALLOWED_STATES = (DEPLOYFAIL, INSPECTING, INSPECTFAIL, INSPECTWAIT,

ironic/conductor/servicing.py

@@ -86,8 +86,6 @@ def do_node_service(task, service_steps=None, disable_ramdisk=False):
         return utils.servicing_error_handler(task, msg)
 
     steps = node.driver_internal_info.get('service_steps', [])
-    if not steps:
-        _tear_down_node_service(task, disable_ramdisk=disable_ramdisk)
     step_index = 0 if steps else None
     do_next_service_step(task, step_index, disable_ramdisk=disable_ramdisk)
 

ironic/conductor/utils.py

@@ -1120,7 +1120,10 @@ def fast_track_able(task):
             # TODO(TheJulia): Should we check the provisioning/deployment
             # networks match config wise? Do we care? #decisionsdecisions
             and task.driver.storage.should_write_image(task)
-            and task.node.last_error is None)
+            and task.node.last_error is None
+            # NOTE(dtantsur): Fast track makes zero sense for servicing and
+            # may prevent normal clean-up from happening.
+            and task.node.provision_state not in states.SERVICING_STATES)
 
 
 def value_within_timeout(value, timeout):

ironic/drivers/modules/deploy_utils.py

@@ -821,21 +821,15 @@ def tear_down_inband_service(task):
 
     task.driver.boot.clean_up_ramdisk(task)
 
-    power_state_to_restore = manager_utils.power_on_node_if_needed(task)
-
     if not service_failure:
-        manager_utils.restore_power_state_if_needed(
-            task, power_state_to_restore)
-
         with manager_utils.power_state_for_network_configuration(task):
             task.driver.network.remove_servicing_network(task)
             task.driver.network.configure_tenant_networks(task)
-        task.driver.boot.prepare_instance(task)
-        manager_utils.restore_power_state_if_needed(
-            task, power_state_to_restore)
 
-        # Change the task instead of return the state.
-        task.process_event('done')
+        task.driver.boot.prepare_instance(task)
+        # prepare_instance does not power on the node, the deploy interface is
+        # normally responsible for that.
+        manager_utils.node_power_action(task, states.POWER_ON)
 
 
 def get_image_instance_info(node):

ironic/tests/unit/conductor/test_utils.py

@@ -2200,6 +2200,13 @@ class FastTrackTestCase(db_base.DbTestCase):
                 self.context, self.node.uuid, shared=False) as task:
             self.assertFalse(conductor_utils.is_fast_track(task))
 
+    def test_is_fast_track_not_in_servicing(self, mock_get_power):
+        mock_get_power.return_value = states.POWER_ON
+        with task_manager.acquire(
+                self.context, self.node.uuid, shared=False) as task:
+            task.node.provision_state = states.SERVICING
+            self.assertFalse(conductor_utils.is_fast_track(task))
+
 
 class GetNodeNextStepsTestCase(db_base.DbTestCase):
     def setUp(self):

ironic/tests/unit/drivers/modules/test_deploy_utils.py

@@ -1071,7 +1071,10 @@ class AgentMethodsTestCase(db_base.DbTestCase):
         with task_manager.acquire(
                 self.context, self.node.uuid, shared=False) as task:
             utils.tear_down_inband_service(task)
-            power_mock.assert_called_once_with(task, states.POWER_OFF)
+            power_mock.assert_has_calls([
+                mock.call(task, states.POWER_OFF),
+                mock.call(task, states.POWER_ON),
+            ])
             remove_service_network_mock.assert_called_once_with(
                 task.driver.network, task)
             clean_up_ramdisk_mock.assert_called_once_with(