test: adjust test for new value unit
This commit is contained in:
@@ -2120,7 +2120,7 @@ def test___now_is_time_to_refresh(default_conf, mocker, exchange_name, time_mach
|
|||||||
# not refreshed yet
|
# not refreshed yet
|
||||||
assert exchange._now_is_time_to_refresh(pair, "5m", candle_type) is True
|
assert exchange._now_is_time_to_refresh(pair, "5m", candle_type) is True
|
||||||
|
|
||||||
last_closed_candle = (start_dt - timedelta(minutes=5)).timestamp()
|
last_closed_candle = dt_ts(start_dt - timedelta(minutes=5))
|
||||||
exchange._pairs_last_refresh_time[(pair, "5m", candle_type)] = last_closed_candle
|
exchange._pairs_last_refresh_time[(pair, "5m", candle_type)] = last_closed_candle
|
||||||
|
|
||||||
# next candle not closed yet
|
# next candle not closed yet
|
||||||
@@ -2523,7 +2523,7 @@ def test_refresh_latest_ohlcv_cache(mocker, default_conf, candle_type, time_mach
|
|||||||
assert len(res[pair1]) == 99
|
assert len(res[pair1]) == 99
|
||||||
assert len(res[pair2]) == 99
|
assert len(res[pair2]) == 99
|
||||||
assert exchange._klines
|
assert exchange._klines
|
||||||
assert exchange._pairs_last_refresh_time[pair1] == ohlcv[-2][0] // 1000
|
assert exchange._pairs_last_refresh_time[pair1] == ohlcv[-2][0]
|
||||||
exchange._api_async.fetch_ohlcv.reset_mock()
|
exchange._api_async.fetch_ohlcv.reset_mock()
|
||||||
|
|
||||||
# Returned from cache
|
# Returned from cache
|
||||||
@@ -2532,7 +2532,7 @@ def test_refresh_latest_ohlcv_cache(mocker, default_conf, candle_type, time_mach
|
|||||||
assert len(res) == 2
|
assert len(res) == 2
|
||||||
assert len(res[pair1]) == 99
|
assert len(res[pair1]) == 99
|
||||||
assert len(res[pair2]) == 99
|
assert len(res[pair2]) == 99
|
||||||
assert exchange._pairs_last_refresh_time[pair1] == ohlcv[-2][0] // 1000
|
assert exchange._pairs_last_refresh_time[pair1] == ohlcv[-2][0]
|
||||||
|
|
||||||
# Move time 1 candle further but result didn't change yet
|
# Move time 1 candle further but result didn't change yet
|
||||||
time_machine.move_to(start + timedelta(hours=101))
|
time_machine.move_to(start + timedelta(hours=101))
|
||||||
@@ -2542,7 +2542,7 @@ def test_refresh_latest_ohlcv_cache(mocker, default_conf, candle_type, time_mach
|
|||||||
assert len(res[pair1]) == 99
|
assert len(res[pair1]) == 99
|
||||||
assert len(res[pair2]) == 99
|
assert len(res[pair2]) == 99
|
||||||
assert res[pair2].at[0, "open"]
|
assert res[pair2].at[0, "open"]
|
||||||
assert exchange._pairs_last_refresh_time[pair1] == ohlcv[-2][0] // 1000
|
assert exchange._pairs_last_refresh_time[pair1] == ohlcv[-2][0]
|
||||||
refresh_pior = exchange._pairs_last_refresh_time[pair1]
|
refresh_pior = exchange._pairs_last_refresh_time[pair1]
|
||||||
|
|
||||||
# New candle on exchange - return 100 candles - but skip one candle so we actually get 2 candles
|
# New candle on exchange - return 100 candles - but skip one candle so we actually get 2 candles
|
||||||
@@ -2560,8 +2560,8 @@ def test_refresh_latest_ohlcv_cache(mocker, default_conf, candle_type, time_mach
|
|||||||
assert res[pair2].at[0, "open"]
|
assert res[pair2].at[0, "open"]
|
||||||
assert refresh_pior != exchange._pairs_last_refresh_time[pair1]
|
assert refresh_pior != exchange._pairs_last_refresh_time[pair1]
|
||||||
|
|
||||||
assert exchange._pairs_last_refresh_time[pair1] == ohlcv[-2][0] // 1000
|
assert exchange._pairs_last_refresh_time[pair1] == ohlcv[-2][0]
|
||||||
assert exchange._pairs_last_refresh_time[pair2] == ohlcv[-2][0] // 1000
|
assert exchange._pairs_last_refresh_time[pair2] == ohlcv[-2][0]
|
||||||
exchange._api_async.fetch_ohlcv.reset_mock()
|
exchange._api_async.fetch_ohlcv.reset_mock()
|
||||||
|
|
||||||
# Retry same call - from cache
|
# Retry same call - from cache
|
||||||
|
|||||||
Reference in New Issue
Block a user