diff --git a/tests/exchange/test_exchange_ws.py b/tests/exchange/test_exchange_ws.py index b8dafb7dd..1e7aaef4c 100644 --- a/tests/exchange/test_exchange_ws.py +++ b/tests/exchange/test_exchange_ws.py @@ -105,9 +105,11 @@ async def test_exchangews_ohlcv(mocker, time_machine): assert exchange_ws._klines_watching == { ("ETH/BTC", "1m", CandleType.SPOT), } + # Cleanup happened. + await asyncio.sleep(0.1) + exchange_ws.schedule_ohlcv("ETH/BTC", "1m", CandleType.SPOT) assert exchange_ws._klines_scheduled == { ("ETH/BTC", "1m", CandleType.SPOT), - ("XRP/BTC", "1m", CandleType.SPOT), } finally: