Pass in daemon name to `start_ahab()`

marketstore
Tyler Goodlet 2022-02-19 16:34:36 -05:00
parent 3eeb1caf32
commit 4af42ee1b5
1 changed files with 8 additions and 2 deletions

View File

@ -54,13 +54,19 @@ def pikerd(loglevel, host, tl, pdb, tsdb):
trio.open_nursery() as n, trio.open_nursery() as n,
): ):
if tsdb: if tsdb:
# TODO:
# async with maybe_open_marketstored():
from piker.data._ahab import start_ahab from piker.data._ahab import start_ahab
log.info('Spawning `marketstore` supervisor') log.info('Spawning `marketstore` supervisor')
ctn_ready = await n.start(start_ahab) ctn_ready = await n.start(
start_ahab,
'marketstored',
)
await ctn_ready.wait() await ctn_ready.wait()
log.info('`marketstore` container:{uid} up') log.info('`marketstore` container:{uid} up')
await trio.sleep_forever() await trio.sleep_forever()
trio.run(main) trio.run(main)