diff --git a/tests/p4rt/test_l3.py b/tests/p4rt/test_l3.py
index dbd6ae9781c6..42f32facbdfe 100644
--- a/tests/p4rt/test_l3.py
+++ b/tests/p4rt/test_l3.py
@@ -23,7 +23,7 @@ def _set_up(self, dvs):
         self._p4rt_route_obj.set_up_databases(dvs)
         self._p4rt_wcmp_group_obj.set_up_databases(dvs)
         self.response_consumer = swsscommon.NotificationConsumer(
-            self._p4rt_route_obj.appl_db, "APPL_DB_P4RT_TABLE_RESPONSE_CHANNEL")
+            self._p4rt_route_obj.appl_state_db, "APPL_DB_P4RT_TABLE_RESPONSE_CHANNEL")
 
     def _set_vrf(self, dvs):
         # Create VRF.
diff --git a/tests/p4rt/test_p4rt_acl.py b/tests/p4rt/test_p4rt_acl.py
index 201a38f9789f..89015fc9d5ee 100644
--- a/tests/p4rt/test_p4rt_acl.py
+++ b/tests/p4rt/test_p4rt_acl.py
@@ -63,7 +63,7 @@ def _set_up(self, dvs):
         self._p4rt_udf_obj.set_up_databases(dvs)
 
         self.response_consumer = swsscommon.NotificationConsumer(
-            self._p4rt_acl_table_definition_obj.appl_db, "APPL_DB_P4RT_TABLE_RESPONSE_CHANNEL"
+            self._p4rt_acl_table_definition_obj.appl_state_db, "APPL_DB_P4RT_TABLE_RESPONSE_CHANNEL"
         )
 
     @pytest.mark.skip(reason="p4orch is not enabled")
diff --git a/tests/p4rt/test_p4rt_mirror.py b/tests/p4rt/test_p4rt_mirror.py
index c62574929350..bc218df14742 100644
--- a/tests/p4rt/test_p4rt_mirror.py
+++ b/tests/p4rt/test_p4rt_mirror.py
@@ -42,7 +42,7 @@ def _set_up(self, dvs):
         self._p4rt_mirror_session_wrapper = P4RtMirrorSessionWrapper()
         self._p4rt_mirror_session_wrapper.set_up_databases(dvs)
         self._response_consumer = swsscommon.NotificationConsumer(
-            self._p4rt_mirror_session_wrapper.appl_db, "APPL_DB_P4RT_TABLE_RESPONSE_CHANNEL")
+            self._p4rt_mirror_session_wrapper.appl_state_db, "APPL_DB_P4RT_TABLE_RESPONSE_CHANNEL")
 
     def test_MirrorSessionAddModifyAndDelete(self, dvs, testlog):
         # Initialize database connectors