From 4cae470f3a1ea6727e814f74069dbb511437eafc Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Tue, 8 Jun 2021 15:57:01 -0400 Subject: [PATCH] Pass "arbiter" socket correctly --- piker/cli/__init__.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/piker/cli/__init__.py b/piker/cli/__init__.py index 0cc38874..e5e9a2d1 100644 --- a/piker/cli/__init__.py +++ b/piker/cli/__init__.py @@ -9,6 +9,7 @@ import tractor from ..log import get_console_log, get_logger, colorize_json from ..brokers import get_brokermod, config +from .._daemon import _tractor_kwargs log = get_logger('cli') @@ -101,8 +102,9 @@ def cli(ctx, brokers, loglevel, tl, configdir): def services(config, tl, names): async def list_services(): + async with tractor.get_arbiter( - *tractor.current_actor()._arb_addr + *_tractor_kwargs['arbiter_addr'] ) as portal: registry = await portal.run('self', 'get_registry') json_d = {} @@ -118,6 +120,7 @@ def services(config, tl, names): list_services, name='service_query', loglevel=config['loglevel'] if tl else None, + arbiter_addr=_tractor_kwargs['arbiter_addr'], )