import asyncio
-import concurrent.futures
+import asyncio.exceptions
import fcntl
import json
import socket
await self.bus.send(Message(self.name,
{'event':
'connection closed'}))
- except (OSError, InvalidMessage, concurrent.futures.TimeoutError):
- pass
+ except (OSError, InvalidMessage,
+ asyncio.exceptions.TimeoutError) as e:
+ print(f"WSClient to {self.conf['url']}: {e}")
await asyncio.sleep(1)
async def _send(self, json_message: str) -> None: