pikers
/
piker
3
0
Fork 0
Code Issues 2 Pull Requests 5 Packages Projects Releases Wiki Activity

Drop `marketstore` loading cruft (will come later)

async_hist_loading
Tyler Goodlet 2022-03-01 12:39:12 -05:00
parent 09079b61fc
commit f7d03489d8
1 changed files with 5 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
piker/data/feed.py
View File

@ -208,14 +208,6 @@ async def manage_history(
buffer. buffer.
''' '''
# TODO: history retreival, see if we can pull from an existing
# ``marketstored`` daemon
log.info('Scanning for existing `marketstored`')
fqsn = mk_fqsn(mod.name, symbol)
# from .marketstore import manage_history
# arrays = await manage_history(symbol)
arrays = {}
task_status.started() task_status.started()
opened = we_opened_shm opened = we_opened_shm
@ -225,21 +217,12 @@ async def manage_history(
# raise RuntimeError("Persistent shm for sym was already open?!") # raise RuntimeError("Persistent shm for sym was already open?!")
if opened: if opened:
if arrays: # ask broker backend for new history
await tractor.breakpoint()
# push to shm # start history backfill task ``backfill_bars()`` is
# set data ready # a required backend func this must block until shm is
# some_data_ready.set() # filled with first set of ohlc bars
raise ValueError('this should never execute yet') cs = await bus.nursery.start(mod.backfill_bars, symbol, shm)
else:
# ask broker backend for new history
# start history backfill task ``backfill_bars()`` is
# a required backend func this must block until shm is
# filled with first set of ohlc bars
cs = await bus.nursery.start(mod.backfill_bars, symbol, shm)
# indicate to caller that feed can be delivered to # indicate to caller that feed can be delivered to
# remote requesting client since we've loaded history # remote requesting client since we've loaded history