Fix entry paths for cleaning and deployment

The explicit removal of agent_url to prevent conflicts...
turned out to be another issue with fast_track.

Change-Id: Ibd93bb255d5664a431f9be9c39c9fc8c67ff7608
Story: 2007080
Task: 37991
(cherry picked from commit 0a94391e34b7d1caa4e99c81ddf4f651f457795e)

3 files changed, 81 insertions, 3 deletions

diff --git a/ironic/conductor/manager.py b/ironic/conductor/manager.py
index d36590057..08ae8a3a3 100644
--- a/ironic/conductor/manager.py
+++ b/ironic/conductor/manager.py
@@ -825,8 +825,10 @@ class ConductorManager(base_manager.BaseConductorManager):
         with task_manager.acquire(context, node_id, shared=False,
                                   purpose='node deployment') as task:
             node = task.node
-            # Record of any pre-existing agent_url should be removed.
-            utils.remove_agent_url(node)
+            # Record of any pre-existing agent_url should be removed
+            # except when we are in fast track conditions.
+            if not utils.is_fast_track(task):
+                utils.remove_agent_url(node)
             if node.maintenance:
                 raise exception.NodeInMaintenance(op=_('provisioning'),
                                                   node=node.uuid)
@@ -1179,7 +1181,10 @@ class ConductorManager(base_manager.BaseConductorManager):
                                   purpose='node manual cleaning') as task:
             node = task.node
             # Record of any pre-existing agent_url should be removed.
-            utils.remove_agent_url(node)
+            if not utils.is_fast_track(task):
+                # If clean->clean with an online agent, we should honor
+                # the operating agent and not prevent the action.
+                utils.remove_agent_url(node)
             if node.maintenance:
                 raise exception.NodeInMaintenance(op=_('cleaning'),
                                                   node=node.uuid)
diff --git a/ironic/tests/unit/conductor/test_manager.py b/ironic/tests/unit/conductor/test_manager.py
index 2e6764097..53cdba3ab 100644
--- a/ironic/tests/unit/conductor/test_manager.py
+++ b/ironic/tests/unit/conductor/test_manager.py
@@ -1754,6 +1754,41 @@ class ServiceDoNodeDeployTestCase(mgr_utils.ServiceSetUpMixin,
             mock_iwdi.assert_called_once_with(self.context, node.instance_info)
             self.assertFalse(node.driver_internal_info['is_whole_disk_image'])
 
+    @mock.patch('ironic.drivers.modules.fake.FakeDeploy.deploy')
+    @mock.patch('ironic.conductor.utils.remove_agent_url')
+    @mock.patch('ironic.conductor.utils.is_fast_track')
+    def test_do_node_deploy_fast_track(self, mock_is_fast_track,
+                                       mock_remove_agent_url,
+                                       mock_deploy, mock_iwdi):
+        # TODO(rloo): delete this after the deprecation period for supporting
+        # non deploy_steps.
+        # Mocking FakeDeploy.deploy before starting the service, causes
+        # it not to be a deploy_step.
+        mock_iwdi.return_value = False
+        mock_is_fast_track.return_value = True
+        self._start_service()
+        mock_deploy.return_value = states.DEPLOYDONE
+        node = obj_utils.create_test_node(
+            self.context, driver='fake-hardware',
+            driver_internal_info={'agent_url': 'meow'},
+            provision_state=states.AVAILABLE,
+            target_provision_state=states.NOSTATE)
+
+        self.service.do_node_deploy(self.context, node.uuid)
+        self._stop_service()
+        node.refresh()
+        self.assertEqual(states.ACTIVE, node.provision_state)
+        self.assertEqual(states.NOSTATE, node.target_provision_state)
+        # last_error should be None.
+        self.assertIsNone(node.last_error)
+        # Verify reservation has been cleared.
+        self.assertIsNone(node.reservation)
+        mock_deploy.assert_called_once_with(mock.ANY)
+        mock_iwdi.assert_called_once_with(self.context, node.instance_info)
+        self.assertFalse(node.driver_internal_info['is_whole_disk_image'])
+        mock_is_fast_track.assert_called_once_with(mock.ANY)
+        mock_remove_agent_url.assert_not_called()
+
 
 @mgr_utils.mock_record_keepalive
 class ContinueNodeDeployTestCase(mgr_utils.ServiceSetUpMixin,
@@ -3453,6 +3488,37 @@ class DoNodeCleanTestCase(mgr_utils.ServiceSetUpMixin, db_base.DbTestCase):
         self.assertNotIn('clean_steps', node.driver_internal_info)
         self.assertIsNone(node.last_error)
 
+    @mock.patch('ironic.conductor.utils.remove_agent_url')
+    @mock.patch('ironic.conductor.utils.is_fast_track')
+    @mock.patch('ironic.conductor.manager.ConductorManager._spawn_worker',
+                autospec=True)
+    @mock.patch('ironic.drivers.modules.network.flat.FlatNetwork.validate',
+                autospec=True)
+    @mock.patch('ironic.drivers.modules.fake.FakePower.validate',
+                autospec=True)
+    def test_do_node_clean_ok_fast_track(
+            self, mock_power_valid, mock_network_valid, mock_spawn,
+            mock_is_fast_track, mock_remove_agent_url):
+        node = obj_utils.create_test_node(
+            self.context, driver='fake-hardware',
+            provision_state=states.MANAGEABLE,
+            driver_internal_info={'agent_url': 'meow'})
+        mock_is_fast_track.return_value = True
+        self._start_service()
+        clean_steps = [self.deploy_raid]
+        self.service.do_node_clean(self.context, node.uuid, clean_steps)
+        mock_power_valid.assert_called_once_with(mock.ANY, mock.ANY)
+        mock_network_valid.assert_called_once_with(mock.ANY, mock.ANY)
+        mock_spawn.assert_called_with(
+            self.service, self.service._do_node_clean, mock.ANY, clean_steps)
+        node.refresh()
+        # Node will be moved to CLEANING
+        self.assertEqual(states.CLEANING, node.provision_state)
+        self.assertEqual(states.MANAGEABLE, node.target_provision_state)
+        self.assertNotIn('clean_steps', node.driver_internal_info)
+        mock_is_fast_track.assert_called_once_with(mock.ANY)
+        mock_remove_agent_url.assert_not_called()
+
     @mock.patch('ironic.conductor.manager.ConductorManager._spawn_worker',
                 autospec=True)
     @mock.patch('ironic.drivers.modules.network.flat.FlatNetwork.validate',
diff --git a/releasenotes/notes/fix-fast-track-entry-path-467c20f97aeb2f4b.yaml b/releasenotes/notes/fix-fast-track-entry-path-467c20f97aeb2f4b.yaml
new file mode 100644
index 000000000..146e95748
--- /dev/null
+++ b/releasenotes/notes/fix-fast-track-entry-path-467c20f97aeb2f4b.yaml
@@ -0,0 +1,7 @@
+---
+fixes:
+  - |
+    Corrects logic in the entry path of node cleaning and deployment
+    processes to prohibit ``agent_url`` from being preemptively removed
+    if ``fast_track`` is enabled and in use. This allows fast track cleaning
+    and deployment operations to succeed.