mohammadian7/freqtrade
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Extract connection reset from exchange_ws

Browse Source
This commit is contained in:
Matthias
2024-05-31 06:48:38 +02:00
parent 7e736a34dd
commit 33e61b1308
1 changed files with 12 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
freqtrade/exchange/exchange_ws.py
+12 -3
View File
@@ -46,15 +46,24 @@ class ExchangeWS:
for task in self._background_tasks: for task in self._background_tasks:
task.cancel() task.cancel()
if hasattr(self, "_loop"): if hasattr(self, "_loop"):
asyncio.run_coroutine_threadsafe(self._cleanup_async(), loop=self._loop) self.reset_connections()
while not self.__cleanup_called:
time.sleep(0.1)
self._loop.call_soon_threadsafe(self._loop.stop) self._loop.call_soon_threadsafe(self._loop.stop)
self._thread.join() self._thread.join()
logger.debug("Stopped") logger.debug("Stopped")
def reset_connections(self) -> None:
"""
Reset all connections - avoids "connection-reset" errors that happen after ~9 days
"""
if hasattr(self, "_loop"):
logger.info("Resetting WS connections.")
asyncio.run_coroutine_threadsafe(self._cleanup_async(), loop=self._loop)
while not self.__cleanup_called:
time.sleep(0.1)
self.__cleanup_called = False
async def _cleanup_async(self) -> None: async def _cleanup_async(self) -> None:
try: try:
await self.ccxt_object.close() await self.ccxt_object.close()