diff --git a/piker/brokers/_daemon.py b/piker/brokers/_daemon.py index 5414bfb9..eb5c2021 100644 --- a/piker/brokers/_daemon.py +++ b/piker/brokers/_daemon.py @@ -59,7 +59,7 @@ _data_mods: str = [ async def _setup_persistent_brokerd( ctx: tractor.Context, brokername: str, - loglevel: str | None = None, + loglevel: str|None = None, ) -> None: ''' @@ -72,10 +72,14 @@ async def _setup_persistent_brokerd( # since all hosted daemon tasks will reference this same # log instance's (actor local) state and thus don't require # any further (level) configuration on their own B) + actor: tractor.Actor = tractor.current_actor() + tll: str = actor.loglevel log = _util.get_console_log( - loglevel or tractor.current_actor().loglevel, + level=loglevel or tll, name=f'{_util.subsys}.{brokername}', + with_tractor_log=bool(tll), ) + assert log.name == _util.subsys # set global for this actor to this new process-wide instance B) _util.log = log @@ -97,7 +101,7 @@ async def _setup_persistent_brokerd( # NOTE: see ep invocation details inside `.data.feed`. try: async with ( - tractor.trionics.collapse_eg(), + # tractor.trionics.collapse_eg(), trio.open_nursery() as service_nursery ): bus: _FeedsBus = feed.get_feed_bus(