datamain only pushes OHLC's to redis
This commit is contained in:
@@ -7,7 +7,7 @@ from async_lru import alru_cache
|
|||||||
from web3.types import EventData
|
from web3.types import EventData
|
||||||
|
|
||||||
from dexorder import blockchain, config, dec, current_w3
|
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.base.orderlib import Exchange
|
||||||
from dexorder.bin.executable import execute
|
from dexorder.bin.executable import execute
|
||||||
from dexorder.blockstate.blockdata import BlockData
|
from dexorder.blockstate.blockdata import BlockData
|
||||||
@@ -61,7 +61,7 @@ async def main():
|
|||||||
state = None
|
state = None
|
||||||
if memcache:
|
if memcache:
|
||||||
await memcache.connect()
|
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:
|
if db:
|
||||||
db.connect(url=config.datadb_url) # our main database is the data db
|
db.connect(url=config.datadb_url) # our main database is the data db
|
||||||
# noinspection DuplicatedCode
|
# noinspection DuplicatedCode
|
||||||
|
|||||||
Reference in New Issue
Block a user