File tree Expand file tree Collapse file tree 1 file changed +3
-4
lines changed
Expand file tree Collapse file tree 1 file changed +3
-4
lines changed Original file line number Diff line number Diff line change @@ -281,8 +281,8 @@ def _download_pair_history(
281281 "Current End: %s" ,
282282 f"{ data .iloc [- 1 ]['date' ]:{DATETIME_PRINT_FORMAT }} " if not data .empty else "None" ,
283283 )
284- # used to check if the passed in pair_candles are not as old as since_ms
285- # if not then we need more data and so we will have to collect more using the typical method
284+ # used to check if the passed in pair_candles (parallel downloaded) covers since_ms.
285+ # If we need more data, we have to fall back to the standard method.
286286 pair_candles_since_ms = (
287287 dt_ts (pair_candles .iloc [0 ]["date" ])
288288 if pair_candles is not None and len (pair_candles .index ) > 0
@@ -296,7 +296,6 @@ def _download_pair_history(
296296 or erase is True
297297 or pair_candles_since_ms > (since_ms if since_ms else 0 )
298298 ):
299- # Default since_ms to 30 days if nothing is given
300299 new_dataframe = exchange .get_historic_ohlcv (
301300 pair = pair ,
302301 timeframe = timeframe ,
@@ -311,7 +310,7 @@ def _download_pair_history(
311310 )
312311 logger .info (f"Downloaded data for { pair } with length { len (new_dataframe )} ." )
313312 else :
314- new_dataframe = pair_candles # following clean_ohlcv_dataframe can do the clean up
313+ new_dataframe = pair_candles
315314 logger .info (
316315 f"Downloaded data for { pair } with length { len (new_dataframe )} . Parallel Method."
317316 )
You can’t perform that action at this time.
0 commit comments