From aa595ae8cb1da3382535583b3de48ef62773c2ff Mon Sep 17 00:00:00 2001 From: Matthias Date: Sun, 26 Jan 2025 09:41:58 +0100 Subject: [PATCH] refactor: extract binance candle url_segment --- freqtrade/exchange/binance_public_data.py | 16 ++++++++++------ 1 file changed, 10 insertions(+), 6 deletions(-) diff --git a/freqtrade/exchange/binance_public_data.py b/freqtrade/exchange/binance_public_data.py index fdc9a993d..9813db465 100644 --- a/freqtrade/exchange/binance_public_data.py +++ b/freqtrade/exchange/binance_public_data.py @@ -63,12 +63,7 @@ async def download_archive_ohlcv( available in the time range """ try: - if candle_type == CandleType.SPOT: - asset_type_url_segment = "spot" - elif candle_type == CandleType.FUTURES: - asset_type_url_segment = "futures/um" - else: - raise ValueError(f"Unsupported CandleType: {candle_type}") + asset_type_url_segment = candle_type_to_url_segment(candle_type) symbol = markets[pair]["id"] @@ -176,6 +171,15 @@ async def _download_archive_ohlcv( return concat_safe(dfs) +def candle_type_to_url_segment(candle_type: CandleType) -> str: + if candle_type == CandleType.SPOT: + return "spot" + elif candle_type == CandleType.FUTURES: + return "futures/um" + else: + raise ValueError(f"Unsupported CandleType: {candle_type}") + + async def cancel_and_await_tasks(unawaited_tasks): """Cancel and await the tasks""" logger.debug("Try to cancel uncompleted download tasks.")