From 9dd99a71b8aee21fdb244bdba8bb6246f60427dc Mon Sep 17 00:00:00 2001 From: Noah Stapp Date: Wed, 28 Oct 2026 15:01:33 -0400 Subject: [PATCH] PYTHON-6200 Wait for monitor threads/tasks to finish in test_close_closes_sockets --- test/asynchronous/test_client.py | 4 ++++ test/test_client.py | 4 ++++ 2 files changed, 8 insertions(+) diff --git a/test/asynchronous/test_client.py b/test/asynchronous/test_client.py index a39b5b1384..2b61dda182 100644 --- a/test/asynchronous/test_client.py +++ b/test/asynchronous/test_client.py @@ -1456,6 +1456,10 @@ async def test_close_closes_sockets(self): topology = client._topology await client.close() for server in topology._servers.values(): + # Wait for monitor tasks to finish. + # Can be removed once PYTHON-1634 is implemented. + await server._monitor._executor.join(10) + await server._monitor._rtt_monitor._executor.join(10) self.assertFalse(server._pool.conns) self.assertTrue(server._monitor._executor._stopped) self.assertTrue(server._monitor._rtt_monitor._executor._stopped) diff --git a/test/test_client.py b/test/test_client.py index 378f6c9f8f..dff1bea01f 100644 --- a/test/test_client.py +++ b/test/test_client.py @@ -1425,6 +1425,10 @@ def test_close_closes_sockets(self): topology = client._topology client.close() for server in topology._servers.values(): + # Wait for monitor tasks to finish. + # Can be removed once PYTHON-1634 is implemented. + server._monitor._executor.join(10) + server._monitor._rtt_monitor._executor.join(10) self.assertFalse(server._pool.conns) self.assertTrue(server._monitor._executor._stopped) self.assertTrue(server._monitor._rtt_monitor._executor._stopped)