Pass in daemon name to `start_ahab()`
parent
8fb9308e21
commit
aea42ccbd9
|
@ -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)
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue