pikers
/
piker
3
0
Fork 0
Code Issues 5 Pull Requests 7 Packages Projects Releases Wiki Activity

Allow passing `allow_overruns: bool` to `Services.start_service_task()`

master
Tyler Goodlet 2023-05-13 16:51:11 -04:00
parent b572cd1b77
commit 2e8268b53e
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
piker/service/_mngr.py
View File

@ -56,6 +56,7 @@ class Services:
name: str, name: str,
portal: tractor.Portal, portal: tractor.Portal,
target: Callable, target: Callable,
allow_overruns: bool = False,
**ctx_kwargs, **ctx_kwargs,
) -> (trio.CancelScope, tractor.Context): ) -> (trio.CancelScope, tractor.Context):
@ -81,6 +82,7 @@ class Services:
with trio.CancelScope() as cs: with trio.CancelScope() as cs:
async with portal.open_context( async with portal.open_context(
target, target,
allow_overruns=allow_overruns,
**ctx_kwargs, **ctx_kwargs,
) as (ctx, first): ) as (ctx, first):