Pass in daemon name to `start_ahab()`

m4_corrections
Tyler Goodlet 2022-02-19 16:34:36 -05:00
parent f1747749e7
commit ae1d9efa97
1 changed files with 8 additions and 2 deletions

View File

@ -54,9 +54,15 @@ 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')