Improved "task done" message

This commit is contained in:
Matthias
2024-05-31 07:12:02 +02:00
parent 8b90643f3a
commit 122896f9ab
+4 -2
View File
@@ -113,12 +113,14 @@ class ExchangeWS:
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 = "done"
if task.cancelled(): if task.cancelled():
result = "cancelled" result = "cancelled"
else: else:
result = task.result() if (result1 := task.result()) is not None:
result = str(result1)
logger.info(f"{pair}, {timeframe} Task finished: {result}") logger.info(f"{pair}, {timeframe}, {candle_type} - 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(