Deepcopy ccxt ws result

This commit is contained in:
Matthias
2024-04-26 18:18:39 +00:00
parent d5d818be8b
commit 765fa06daa
+3 -1
View File
@@ -2,6 +2,7 @@
import asyncio import asyncio
import logging import logging
import time import time
from copy import deepcopy
from functools import partial from functools import partial
from threading import Thread from threading import Thread
from typing import Dict, Set from typing import Dict, Set
@@ -147,7 +148,8 @@ class ExchangeWS:
Returns cached klines from ccxt's "watch" cache. Returns cached klines from ccxt's "watch" cache.
:param candle_date: timestamp of the end-time of the candle. :param candle_date: timestamp of the end-time of the candle.
""" """
candles = self.ccxt_object.ohlcvs.get(pair, {}).get(timeframe) # Deepcopy the response - as it might be modified in the background as new messages arrive
candles = deepcopy(self.ccxt_object.ohlcvs.get(pair, {}).get(timeframe))
refresh_date = self.klines_last_refresh[(pair, timeframe, candle_type)] refresh_date = self.klines_last_refresh[(pair, timeframe, candle_type)]
drop_hint = False drop_hint = False
if refresh_date > candle_date: if refresh_date > candle_date: