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

Drop `Optional` use from daemon mod

pre_overruns_ctxcancelled
Tyler Goodlet 2023-03-27 14:21:09 -04:00
parent 7c3418def6
commit d644436a3c
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
piker/service/_daemon.py
View File

@ -20,7 +20,6 @@ Daemon-actor spawning "endpoint-hooks".
""" """
from __future__ import annotations from __future__ import annotations
from typing import ( from typing import (
Optional,
Callable, Callable,
Any, Any,
) )
@ -42,6 +41,7 @@ from ._actor_runtime import maybe_open_pikerd
from ._registry import find_service from ._registry import find_service
# `brokerd` enabled modules # `brokerd` enabled modules
# TODO: move this def to the `.data` subpkg..
# NOTE: keeping this list as small as possible is part of our caps-sec # NOTE: keeping this list as small as possible is part of our caps-sec
# model and should be treated with utmost care! # model and should be treated with utmost care!
_data_mods = [ _data_mods = [
@ -59,7 +59,7 @@ async def maybe_spawn_daemon(
service_name: str, service_name: str,
service_task_target: Callable, service_task_target: Callable,
spawn_args: dict[str, Any], spawn_args: dict[str, Any],
loglevel: Optional[str] = None, loglevel: str | None = None,
singleton: bool = False, singleton: bool = False,
**kwargs, **kwargs,
@ -100,7 +100,6 @@ async def maybe_spawn_daemon(
# pikerd is not live we now become the root of the # pikerd is not live we now become the root of the
# process tree # process tree
async with maybe_open_pikerd( async with maybe_open_pikerd(
loglevel=loglevel, loglevel=loglevel,
**kwargs, **kwargs,
@ -141,7 +140,8 @@ async def maybe_spawn_daemon(
async def spawn_brokerd( async def spawn_brokerd(
brokername: str, brokername: str,
loglevel: Optional[str] = None, loglevel: str | None = None,
**tractor_kwargs, **tractor_kwargs,
) -> bool: ) -> bool:
@ -190,7 +190,7 @@ async def spawn_brokerd(
async def maybe_spawn_brokerd( async def maybe_spawn_brokerd(
brokername: str, brokername: str,
loglevel: Optional[str] = None, loglevel: str | None = None,
**kwargs, **kwargs,
) -> tractor.Portal: ) -> tractor.Portal:
@ -216,7 +216,7 @@ async def maybe_spawn_brokerd(
async def spawn_emsd( async def spawn_emsd(
loglevel: Optional[str] = None, loglevel: str | None = None,
**extra_tractor_kwargs **extra_tractor_kwargs
) -> bool: ) -> bool:
@ -252,7 +252,7 @@ async def spawn_emsd(
async def maybe_open_emsd( async def maybe_open_emsd(
brokername: str, brokername: str,
loglevel: Optional[str] = None, loglevel: str | None = None,
**kwargs, **kwargs,
) -> tractor._portal.Portal: # noqa ) -> tractor._portal.Portal: # noqa