diff --git a/tests/integration/backward_compatible/proxy/reliable_topic_test.py b/tests/integration/backward_compatible/proxy/reliable_topic_test.py
index 2e7f369f8a..8238fecdcc 100644
--- a/tests/integration/backward_compatible/proxy/reliable_topic_test.py
+++ b/tests/integration/backward_compatible/proxy/reliable_topic_test.py
@@ -117,7 +117,7 @@ def on_cancel(self):
 
         self.assertTrueEventually(lambda: self.assertEqual(["a", "b"], messages))
 
-        self.assertEquals(0, on_cancel_call_count[0])
+        self.assertEqual(0, on_cancel_call_count[0])
 
     def test_add_listener_with_retrieve_initial_sequence(self):
         topic = self.get_topic(random_string())
@@ -278,7 +278,7 @@ def on_cancel(self) -> None:
         # Should be cancelled since on_message raised error
         self.assertTrueEventually(lambda: self.assertEqual(0, len(topic._wrapped._runners)))
 
-        self.assertEquals(1, on_cancel_call_count[0])
+        self.assertEqual(1, on_cancel_call_count[0])
 
     def test_add_listener_when_on_message_and_is_terminal_raises_error(self):
         topic = self.get_topic(random_string())
@@ -320,7 +320,7 @@ def on_cancel(self) -> None:
         # Should be cancelled since on_message raised error
         self.assertTrueEventually(lambda: self.assertEqual(0, len(topic._wrapped._runners)))
 
-        self.assertEquals(1, on_cancel_call_count[0])
+        self.assertEqual(1, on_cancel_call_count[0])
 
     def test_add_listener_with_non_callable(self):
         topic = self.get_topic(random_string())
@@ -353,7 +353,7 @@ def on_cancel(self) -> None:
 
         registration_id = topic.add_listener(Listener())
         self.assertTrue(topic.remove_listener(registration_id))
-        self.assertEquals(1, on_cancel_call_count[0])
+        self.assertEqual(1, on_cancel_call_count[0])
 
     def test_remove_listener_does_not_receive_messages_after_removal(self):
         topic = self.get_topic(random_string())