CTYPTO/freqtrade
1
0
Fork 0
mirror of https://github.com/freqtrade/freqtrade.git synced 2025-11-29 00:23:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: simplify exchangews_ohlcv further

Browse Source
This commit is contained in:
Matthias
2025-07-04 15:24:44 +02:00
parent 5101b1767b
commit 81fdff1039
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
tests/exchange/test_exchange_ws.py
View File

@@ -118,22 +118,22 @@ async def test_exchangews_ohlcv(mocker, time_machine, caplog):
# Wait for the expected number of watch calls
await wait_for_condition(lambda: ccxt_object.watch_ohlcv.call_count >= 6, timeout=3.0)
assert ccxt_object.watch_ohlcv.call_count == 6
assert ccxt_object.watch_ohlcv.call_count >= 6
ccxt_object.watch_ohlcv.reset_mock()
time_machine.shift(timedelta(minutes=5))
exchange_ws.schedule_ohlcv("ETH/BTC", "1m", CandleType.SPOT)
# Wait for log message and state changes with timeout
# Wait for log message
await wait_for_condition(
lambda: log_has_re("un_watch_ohlcv_for_symbols not supported: ", caplog), timeout=2.0
)
assert log_has_re("un_watch_ohlcv_for_symbols not supported: ", caplog)
# Wait for XRP/BTC cleanup
await wait_for_condition(
lambda: exchange_ws._klines_watching == {("ETH/BTC", "1m", CandleType.SPOT)},
timeout=2.0,
)
# XRP/BTC should be cleaned up.
assert exchange_ws._klines_watching == {
("ETH/BTC", "1m", CandleType.SPOT),
}
# Cleanup happened.
ccxt_object.un_watch_ohlcv_for_symbols = AsyncMock(side_effect=ValueError)