diff --git a/freqtrade/exchange/common.py b/freqtrade/exchange/common.py index a4c827e07..d10682a61 100644 --- a/freqtrade/exchange/common.py +++ b/freqtrade/exchange/common.py @@ -1,12 +1,15 @@ import asyncio import logging import time -from functools import wraps +from functools import partial, wraps from freqtrade.exceptions import DDosProtection, RetryableOrderError, TemporaryError +from freqtrade.mixins import LoggingMixin logger = logging.getLogger(__name__) +logging_mixin = LoggingMixin(logger) +log_once_warning = partial(logging_mixin.log_once, logmethod=logger.warning) # Maximum default retry count. @@ -84,7 +87,7 @@ def retrier_async(f): if "kucoin" in str(ex) and "429000" in str(ex): # Temporary fix for 429000 error on kucoin # see https://github.com/freqtrade/freqtrade/issues/5700 for details. - logger.warning( + log_once_warning( f"Kucoin 429 error, avoid triggering DDosProtection backoff delay. " f"{count} tries left before giving up") else: diff --git a/tests/exchange/test_exchange.py b/tests/exchange/test_exchange.py index a4b151742..9bd419e24 100644 --- a/tests/exchange/test_exchange.py +++ b/tests/exchange/test_exchange.py @@ -1740,6 +1740,28 @@ async def test__async_get_candle_history(default_conf, mocker, caplog, exchange_ (arrow.utcnow().int_timestamp - 2000) * 1000) +@pytest.mark.asyncio +async def test__async_kucoin_get_candle_history(default_conf, mocker, caplog): + caplog.set_level(logging.INFO) + api_mock = MagicMock() + + assert not log_has_re('Kucoin 429 error, avoid triggering DDosProtection backoff delay.*', + caplog) + + for _ in range(3): + with pytest.raises(DDosProtection, match=r'429 Too Many Requests'): + api_mock.fetch_ohlcv = MagicMock(side_effect=ccxt.DDoSProtection( + "kucoin GET https://openapi-v2.kucoin.com/api/v1/market/candles?" + "symbol=ETH-BTC&type=5min&startAt=1640268735&endAt=1640418735" + "429 Too Many Requests" '{"code":"429000","msg":"Too Many Requests"}')) + exchange = get_patched_exchange(mocker, default_conf, api_mock, id="kucoin") + await exchange._async_get_candle_history( + 'ETH/BTC', "5m", (arrow.utcnow().int_timestamp - 2000) * 1000, count=1) + logs_found = sum('Kucoin 429 error, avoid triggering DDosProtection backoff delay' in message + for message in caplog.messages) + assert logs_found == 1 + + @pytest.mark.asyncio async def test__async_get_candle_history_empty(default_conf, mocker, caplog): """ Test empty exchange result """