pikers
/
piker
3
0
Fork 0
Code Issues 4 Pull Requests 6 Packages Projects Releases Wiki Activity

Reset `._registry_addr` to any passed in value from caller

agg_feedz
Tyler Goodlet 2023-01-09 18:15:23 -05:00
parent 81585d9e6e
commit 008ae47e14
1 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
piker/_daemon.py
View File

@ -35,11 +35,11 @@ log = get_logger(__name__)
_root_dname = 'pikerd' _root_dname = 'pikerd'
_registry_host: str = '127.0.0.1' _default_registry_host: str = '127.0.0.1'
_registry_port: int = 6116 _default_registry_port: int = 6116
_default_reg_addr: tuple[str, int] = ( _default_reg_addr: tuple[str, int] = (
_registry_host, _default_registry_host,
_registry_port, _default_registry_port,
) )
# NOTE: this value is set as an actor-global once the first endpoint # NOTE: this value is set as an actor-global once the first endpoint
@ -159,7 +159,10 @@ async def open_pikerd(
global _services global _services
global _registry_addr global _registry_addr
if _registry_addr is None: if (
_registry_addr is None
or registry_addr
):
_registry_addr = registry_addr or _default_reg_addr _registry_addr = registry_addr or _default_reg_addr
# XXX: this may open a root actor as well # XXX: this may open a root actor as well
@ -217,7 +220,10 @@ async def open_piker_runtime(
global _services global _services
global _registry_addr global _registry_addr
if _registry_addr is None: if (
_registry_addr is None
or registry_addr
):
_registry_addr = registry_addr or _default_reg_addr _registry_addr = registry_addr or _default_reg_addr
# XXX: this may open a root actor as well # XXX: this may open a root actor as well