dexorder/backend
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

log tweaks

Browse Source
This commit is contained in:
tim
2024-10-23 16:04:28 -04:00
parent 829ec58f8f
commit 6844f73e4b
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/dexorder/blockstate/db_state.py
View File

@@ -91,22 +91,25 @@ class DbState(SeriesCollection):
root_fork = state.init_root_block(root_block) root_fork = state.init_root_block(root_block)
for series, data in self.datas.items(): for series, data in self.datas.items():
if data.opts.get('db') != 'lazy': if data.opts.get('db') != 'lazy':
log.debug(f'loading series {series}')
t = data.type t = data.type
count = 0
if t == DataType.SET: if t == DataType.SET:
# noinspection PyTypeChecker # noinspection PyTypeChecker
var: BlockSet = BlockData.registry[series] var: BlockSet = BlockData.registry[series]
for row in db.session.query(SeriesSet).where(SeriesSet.chain == chain_id, SeriesSet.series == data.series2str(series)): for row in db.session.query(SeriesSet).where(SeriesSet.chain == chain_id, SeriesSet.series == data.series2str(series)):
key = data.str2key(row.key) key = data.str2key(row.key)
log.debug(f'load {series} {key}') # log.debug(f'load {series} {key}')
state.set(root_fork, var.series, key, None, overwrite=False) state.set(root_fork, var.series, key, None, overwrite=False)
count += 1
elif t == DataType.DICT: elif t == DataType.DICT:
# noinspection PyTypeChecker # noinspection PyTypeChecker
var: BlockDict = BlockData.registry[series] var: BlockDict = BlockData.registry[series]
for row in db.session.query(SeriesDict).where(SeriesDict.chain == chain_id, SeriesDict.series == data.series2str(series)): for row in db.session.query(SeriesDict).where(SeriesDict.chain == chain_id, SeriesDict.series == data.series2str(series)):
key = data.str2key(row.key) key = data.str2key(row.key)
value = data.str2value(row.value) value = data.str2value(row.value)
log.debug(f'load {series} {key} {value}') # log.debug(f'load {series} {key} {value}')
state.set(root_fork, var.series, key, value, overwrite=True) state.set(root_fork, var.series, key, value, overwrite=True)
count += 1
log.debug(f'loaded {count} rows from db series {series}')
log.debug(f'loaded db state from block {root_block}') log.debug(f'loaded db state from block {root_block}')
return state return state