diff --git a/coriolis/conductor/rpc/server.py b/coriolis/conductor/rpc/server.py
index 92ff8383..ecdb6d64 100644
--- a/coriolis/conductor/rpc/server.py
+++ b/coriolis/conductor/rpc/server.py
@@ -2156,7 +2156,6 @@ def cancel_migration(self, ctxt, migration_id, force):
                 constants.EXECUTION_LOCK_NAME_FORMAT % execution.id,
                 external=True):
             self._cancel_tasks_execution(ctxt, execution, force=force)
-        self._check_delete_reservation_for_transfer(migration)
 
     def _cancel_tasks_execution(
             self, ctxt, execution, requery=True, force=False):
@@ -3301,6 +3300,10 @@ def confirm_task_cancellation(self, ctxt, task_id, cancellation_details):
                 "confirmation of its cancellation.",
                 task.id, task.status, final_status)
             execution = db_api.get_tasks_execution(ctxt, task.execution_id)
+            if execution.type == constants.EXECUTION_TYPE_MIGRATION:
+                action = db_api.get_action(
+                    ctxt, execution.action_id, include_task_info=False)
+                self._check_delete_reservation_for_transfer(action)
             self._advance_execution_state(ctxt, execution, requery=False)
 
     @parent_tasks_execution_synchronized
diff --git a/coriolis/tests/conductor/rpc/test_server.py b/coriolis/tests/conductor/rpc/test_server.py
index 80b53302..37ca2714 100644
--- a/coriolis/tests/conductor/rpc/test_server.py
+++ b/coriolis/tests/conductor/rpc/test_server.py
@@ -3770,8 +3770,6 @@ def test_delete_migration(
         )
         mock_delete_migration.assert_not_called()
 
-    @mock.patch.object(server.ConductorServerEndpoint,
-                       '_check_delete_reservation_for_transfer')
     @mock.patch.object(server.ConductorServerEndpoint,
                        '_cancel_tasks_execution')
     @mock.patch.object(lockutils, 'lock')
@@ -3783,7 +3781,6 @@ def test_cancel_migration(
         mock_get_migration,
         mock_lock,
         mock_cancel_tasks_execution,
-        mock_check_delete_reservation_for_transfer,
         config,
         raises_exception
     ):
@@ -3822,8 +3819,6 @@ def test_cancel_migration(
                 execution,
                 force=force
             )
-            mock_check_delete_reservation_for_transfer.assert_called_once_with(
-                migration)
 
         mock_get_migration.assert_called_once_with(
             mock.sentinel.context,
@@ -5018,6 +5013,9 @@ def test_cancel_execution_for_osmorphing_debugging(
 
     @mock.patch.object(server.ConductorServerEndpoint,
                        "_advance_execution_state")
+    @mock.patch.object(server.ConductorServerEndpoint,
+                       "_check_delete_reservation_for_transfer")
+    @mock.patch.object(db_api, "get_action")
     @mock.patch.object(db_api, "get_tasks_execution")
     @mock.patch.object(db_api, "set_task_status")
     @mock.patch.object(db_api, "get_task")
@@ -5028,6 +5026,8 @@ def test_confirm_task_cancellation(
         mock_get_task,
         mock_set_task_status,
         mock_get_tasks_execution,
+        mock_get_action,
+        mock_check_delete_reservation,
         mock_advance_execution_state,
         task_status,
         expected_final_status,
@@ -5037,6 +5037,9 @@ def test_confirm_task_cancellation(
         task.status = getattr(constants, task_status)
         expected_final_status = getattr(constants, expected_final_status)
         mock_get_task.return_value = task
+        mock_execution = mock.MagicMock()
+        mock_execution.type = constants.EXECUTION_TYPE_MIGRATION
+        mock_get_tasks_execution.return_value = mock_execution
 
         testutils.get_wrapped_function(self.server.confirm_task_cancellation)(
             self.server,
@@ -5054,6 +5057,11 @@ def test_confirm_task_cancellation(
         if expected_advance_execution_state_call:
             mock_get_tasks_execution.assert_called_once_with(
                 mock.sentinel.context, task.execution_id)
+            mock_get_action.assert_called_once_with(
+                mock.sentinel.context, mock_execution.action_id,
+                include_task_info=False)
+            mock_check_delete_reservation.assert_called_once_with(
+                mock_get_action.return_value)
             mock_advance_execution_state.assert_called_once_with(
                 mock.sentinel.context,
                 mock_get_tasks_execution.return_value,