diff --git a/src/dexorder/bin/datamain.py b/src/dexorder/bin/datamain.py index 9a6a92a..e06c8d5 100644 --- a/src/dexorder/bin/datamain.py +++ b/src/dexorder/bin/datamain.py @@ -7,7 +7,7 @@ from async_lru import alru_cache from web3.types import EventData from dexorder import blockchain, config, dec, current_w3 -from dexorder.base.ohlc import ohlcs +from dexorder.base.ohlc import ohlcs, recent_ohlcs from dexorder.base.orderlib import Exchange from dexorder.bin.executable import execute from dexorder.blockstate.blockdata import BlockData @@ -61,7 +61,7 @@ async def main(): state = None if memcache: await memcache.connect() - redis_state = RedisState(BlockData.by_opt('redis')) + redis_state = RedisState([recent_ohlcs]) # NOTE: ONLY the ohlc's are pushed to Redis. We do not want to touch anything else. if db: db.connect(url=config.datadb_url) # our main database is the data db # noinspection DuplicatedCode