Yield services (manager) from `maybe_open_pikerd()`
parent
844626f6dc
commit
d9b73e1d08
|
@ -22,9 +22,9 @@ from __future__ import annotations
|
||||||
import os
|
import os
|
||||||
from typing import (
|
from typing import (
|
||||||
Optional,
|
Optional,
|
||||||
Union,
|
|
||||||
Callable,
|
Callable,
|
||||||
Any,
|
Any,
|
||||||
|
ClassVar,
|
||||||
)
|
)
|
||||||
from contextlib import (
|
from contextlib import (
|
||||||
asynccontextmanager as acm,
|
asynccontextmanager as acm,
|
||||||
|
@ -393,7 +393,7 @@ async def maybe_open_pikerd(
|
||||||
|
|
||||||
**kwargs,
|
**kwargs,
|
||||||
|
|
||||||
) -> Union[tractor._portal.Portal, Services]:
|
) -> tractor._portal.Portal | ClassVar[Services]:
|
||||||
'''
|
'''
|
||||||
If no ``pikerd`` daemon-root-actor can be found start it and
|
If no ``pikerd`` daemon-root-actor can be found start it and
|
||||||
yield up (we should probably figure out returning a portal to self
|
yield up (we should probably figure out returning a portal to self
|
||||||
|
@ -445,7 +445,7 @@ async def maybe_open_pikerd(
|
||||||
# tractor-piker runtime stack in **this** process
|
# tractor-piker runtime stack in **this** process
|
||||||
# we return no portal to self.
|
# we return no portal to self.
|
||||||
assert service_manager
|
assert service_manager
|
||||||
yield None
|
yield service_manager
|
||||||
|
|
||||||
|
|
||||||
# `brokerd` enabled modules
|
# `brokerd` enabled modules
|
||||||
|
|
Loading…
Reference in New Issue