There was an error while loading. Please reload this page.
1 parent ee1d7b0 commit 4f88810Copy full SHA for 4f88810
tests/system.py
@@ -446,7 +446,11 @@ def test_subscriber_not_leaking_open_sockets(
446
assert len(response.received_messages) == 3
447
448
conn_count_end = len(current_process.connections())
449
- assert conn_count_end == conn_count_start
+
450
+ # To avoid flakiness, use <= in the assertion, since on rare occasions additional
451
+ # sockets are closed, causing the == assertion to fail.
452
+ # https://github.com/googleapis/python-pubsub/issues/483#issuecomment-910122086
453
+ assert conn_count_end <= conn_count_start
454
455
456
def test_synchronous_pull_no_deadline_error_if_no_messages(
0 commit comments