Skip to content

Commit

Permalink
Changed assertEquals to assertEqual since this fails on Python 3.12.
Browse files Browse the repository at this point in the history
  • Loading branch information
ihsandemir committed Jan 3, 2024
1 parent ad57726 commit b795f4a
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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())
Expand Down Expand Up @@ -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())
Expand Down Expand Up @@ -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())
Expand Down Expand Up @@ -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())
Expand Down

0 comments on commit b795f4a

Please sign in to comment.