diff --git a/sdk/python/kfp/local/task_dispatcher_test.py b/sdk/python/kfp/local/task_dispatcher_test.py
index c158fb25e68..753fd7b3dc0 100644
--- a/sdk/python/kfp/local/task_dispatcher_test.py
+++ b/sdk/python/kfp/local/task_dispatcher_test.py
@@ -122,7 +122,7 @@ def my_pipeline():
         my_pipeline = testing_utilities.compile_and_load_component(my_pipeline)
         with self.assertRaisesRegex(
                 NotImplementedError,
-                'Local pipeline execution is not currently supported\.',
+                r'Local pipeline execution is not currently supported\.',
         ):
             my_pipeline()
 
@@ -142,7 +142,7 @@ def my_pipeline():
         my_pipeline = testing_utilities.compile_and_load_component(my_pipeline)
         with self.assertRaisesRegex(
                 NotImplementedError,
-                'Local pipeline execution is not currently supported\.',
+                r'Local pipeline execution is not currently supported\.',
         ):
             my_pipeline()
 
@@ -160,7 +160,7 @@ def my_pipeline(string: str) -> str:
 
         with self.assertRaisesRegex(
                 NotImplementedError,
-                'Local pipeline execution is not currently supported\.',
+                r'Local pipeline execution is not currently supported\.',
         ):
             my_pipeline(string='foo')