adelorenzo/stable
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fixed some minor issues

Browse Source
This commit is contained in:
Mohammad Dashti 2021-09-17 00:44:19 -07:00
parent ddba69af71
commit 462fc78f33
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
freqtrade/exchange/exchange.py
View File

@ -1450,12 +1450,12 @@ class Exchange:
if cached_res: if cached_res:
return cached_res return cached_res
logger.debug("Caching intervals for pair %s", pair) logger.debug("Reading cached intervals for pair %s", pair)
cache_interval_tree = IntervalTree() cache_interval_tree = IntervalTree()
tmpdata_dir = self._intermediate_trades_dir_for_pair(datadir, pair) tmpdata_dir = self._intermediate_trades_dir_for_pair(datadir, pair)
await self._async_read_interval_tree_for_pair(tmpdata_dir, pair, cache_interval_tree) await self._async_read_interval_tree_for_pair(tmpdata_dir, pair, cache_interval_tree)
logger.debug("Cached intervals for pair %s: %s intervals", pair, len(cache_interval_tree)) logger.debug("Read cached intervals for pair %s: %s intervals", pair, len(cache_interval_tree))
self._intermediate_data_cache[pair] = cache_interval_tree self._intermediate_data_cache[pair] = cache_interval_tree
return cache_interval_tree return cache_interval_tree
@ -1504,7 +1504,7 @@ class Exchange:
if not from_pg_id: if not from_pg_id:
from_pg_id = trades_list[0][0] from_pg_id = trades_list[0][0]
to_pg_id = trades_list[-1][0] to_pg_id = trades_list[-1][0] + 1 # as it's exclusive
pagination_method = "by_since" pagination_method = "by_since"
pagination_col_index = 1 if pagination_method == "by_id" else 0 pagination_col_index = 1 if pagination_method == "by_id" else 0
@ -1525,7 +1525,7 @@ class Exchange:
if int(from_pg_id) != cached_from_pg_id_interval.begin: if int(from_pg_id) != cached_from_pg_id_interval.begin:
trades_list = list(filter( trades_list = list(filter(
lambda trade: (int(trade[pagination_col_index]) < lambda trade: (int(trade[pagination_col_index]) <
cached_from_pg_id_interval.begin), cached_from_pg_id_interval.end),
trades_list trades_list
)) ))
logger.debug("The result was partially cached in the intermediate result " + logger.debug("The result was partially cached in the intermediate result " +