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

Drop upcoming cached feed usage

supervise
Tyler Goodlet 2021-03-31 14:56:42 -04:00
parent 6891309abd
commit 2b7cecc78e
1 changed files with 0 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
piker/_daemon.py
View File

@ -136,8 +136,6 @@ async def spawn_brokerd(
**tractor_kwargs **tractor_kwargs
) -> tractor._portal.Portal: ) -> tractor._portal.Portal:
from .data import _setup_persistent_feeds
log.info(f'Spawning {brokername} broker daemon') log.info(f'Spawning {brokername} broker daemon')
brokermod = get_brokermod(brokername) brokermod = get_brokermod(brokername)
@ -156,21 +154,6 @@ async def spawn_brokerd(
**tractor_kwargs **tractor_kwargs
) )
# TODO: so i think this is the perfect use case for supporting
# a cross-actor async context manager api instead of this
# shoort-and-forget task spawned in the root nursery, we'd have an
# async exit stack that we'd register the `portal.open_context()`
# call with and then have the ability to unwind the call whenevs.
# non-blocking setup of brokerd service nursery
_services.service_n.start_soon(
partial(
portal.run,
_setup_persistent_feeds,
brokername=brokername,
)
)
return dname return dname