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

Properly handle shutdown (canceled coroutines)

Browse Source 
This will imrove shutdown behavior
This commit is contained in:
Matthias
2024-04-25 09:38:14 +02:00
parent 68c36ce07d
commit ed8b9018c5
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
freqtrade/exchange/exchange_ws.py
+6 -2
View File
@@ -102,8 +102,12 @@ class ExchangeWS:
def _continuous_stopped( def _continuous_stopped(
self, task: asyncio.Task, pair: str, timeframe: str, candle_type: CandleType): self, task: asyncio.Task, pair: str, timeframe: str, candle_type: CandleType):
self._background_tasks.discard(task) self._background_tasks.discard(task)
result = task.result() if task.cancelled():
logger.info(f"{pair}, {timeframe} Task finished {result}") result = "cancelled"
else:
result = task.result()
logger.info(f"{pair}, {timeframe} Task finished: {result}")
self._klines_scheduled.discard((pair, timeframe, candle_type)) self._klines_scheduled.discard((pair, timeframe, candle_type))
async def _continuously_async_watch_ohlcv( async def _continuously_async_watch_ohlcv(