diff --git a/nova/tests/functional/compute/test_live_migration.py b/nova/tests/functional/compute/test_live_migration.py
index 160a898bda4e..7d957d10ae3c 100644
--- a/nova/tests/functional/compute/test_live_migration.py
+++ b/nova/tests/functional/compute/test_live_migration.py
@@ -167,16 +167,12 @@ class TestVolAttachmentsDuringLiveMigration(
 
         # Migrate the instance and wait until the migration errors out thanks
         # to our mocked version of live_migration raising TestingException
-        self.api.post_server_action(
-            server['id'],
-            {'os-migrateLive': {'host': None, 'block_migration': 'auto'}})
-        self._wait_for_migration_status(server, ['error'])
+        self._live_migrate(server, 'error', server_expected_state='ERROR')
 
         # Assert that we called the fake live_migration method
         mock_lm.assert_called_once()
 
-        # Assert that the instance is listed as ERROR on the source
-        self._wait_for_state_change(server, 'ERROR')
+        # Assert that the instance is on the source
         server = self.api.get_server(server['id'])
         self.assertEqual(src_host, server['OS-EXT-SRV-ATTR:host'])
 
diff --git a/nova/tests/functional/integrated_helpers.py b/nova/tests/functional/integrated_helpers.py
index b17d4696b233..80338f357810 100644
--- a/nova/tests/functional/integrated_helpers.py
+++ b/nova/tests/functional/integrated_helpers.py
@@ -407,13 +407,14 @@ class InstanceHelperMixin(object):
         }
         self._migrate_or_resize(server, resize_req)
 
-    def _live_migrate(self, server, migration_final_status):
+    def _live_migrate(self, server, migration_expected_state,
+                      server_expected_state='ACTIVE'):
         self.api.post_server_action(
             server['id'],
             {'os-migrateLive': {'host': None,
                                 'block_migration': 'auto'}})
-        self._wait_for_state_change(server, 'ACTIVE')
-        self._wait_for_migration_status(server, [migration_final_status])
+        self._wait_for_state_change(server, server_expected_state)
+        self._wait_for_migration_status(server, [migration_expected_state])
 
 
 class _IntegratedTestBase(test.TestCase, InstanceHelperMixin):