pingpong

src/prefect/events/clients.py

@@ -297,12 +297,14 @@ async def __aexit__(
         return await super().__aexit__(exc_type, exc_val, exc_tb)
 
     def raise_for_connection_error(self):
-        with self._sync_connect():
-            pass
+        with self._sync_connect() as ws:
+            pong = ws.ping()
+            pong.wait()
 
     async def araise_for_connection_error(self):
-        async with self._deferred_connect():
-            pass
+        async with self._deferred_connect() as ws:
+            pong = ws.ping()
+            await pong
 
     async def _reconnect(self) -> None:
         assert self._connect