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.")