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

doc/log touchups

Browse Source
This commit is contained in:
Tim
2024-02-17 15:42:08 -04:00
parent ea56487002
commit ed0fcd4454
2 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/dexorder/bin/backfill_ohlc.py
View File

@@ -24,10 +24,7 @@ log = logging.getLogger('dexorder.backfill')
def finalize_callback(block: Block, diffs: Reversible[Union[DiffItem, DiffEntryItem]]): def finalize_callback(block: Block, diffs: Reversible[Union[DiffItem, DiffEntryItem]]):
# start = now()
log.info("finalizing OHLC's")
ohlc_save(block, diffs) ohlc_save(block, diffs)
# log.info(f'\ttook {(now() - start).total_seconds():.1f} seconds')
log.info(f'backfill completed through block {block.height} {from_timestamp(block.timestamp):%Y-%m-%d %H:%M:%S} {hexstr(block.hash)}') log.info(f'backfill completed through block {block.height} {from_timestamp(block.timestamp):%Y-%m-%d %H:%M:%S} {hexstr(block.hash)}')

8
src/dexorder/ohlc.py
View File

@@ -6,7 +6,7 @@ from typing import Optional, NamedTuple, Reversible, Union
from cachetools import LFUCache from cachetools import LFUCache
from dexorder import dec, config, from_timestamp, timestamp from dexorder import dec, config, from_timestamp, timestamp, now
from dexorder.base.chain import current_chain from dexorder.base.chain import current_chain
from dexorder.blockstate import BlockDict, DiffItem, current_blockstate from dexorder.blockstate import BlockDict, DiffItem, current_blockstate
from dexorder.blockstate.diff import DiffEntryItem from dexorder.blockstate.diff import DiffEntryItem
@@ -331,14 +331,20 @@ def ohlc_save(_block: Block, diffs: Reversible[Union[DiffItem, DiffEntryItem]]):
""" """
used as a finalization callback from BlockState data. used as a finalization callback from BlockState data.
""" """
start = now()
log.info("finalizing OHLC's")
dirty = False dirty = False
for diff in diffs: for diff in diffs:
if diff.series == 'ohlc': if diff.series == 'ohlc':
symbol, period = diff.key symbol, period = diff.key
ohlcs.save_all(symbol, period, diff.value) ohlcs.save_all(symbol, period, diff.value)
dirty = True dirty = True
log.info(f'\ttook {(now() - start).total_seconds():.1f} seconds')
start = now()
log.info("flushing OHLC's")
if dirty: if dirty:
ohlcs.flush() ohlcs.flush()
log.info(f'\ttook {(now() - start).total_seconds():.1f} seconds')
def ohlc_value_to_string(bars: list[NativeOHLC]): def ohlc_value_to_string(bars: list[NativeOHLC]):
return '['+','.join(b.json for b in bars)+']' return '['+','.join(b.json for b in bars)+']'