diff --git a/tractor/_forkserver_override.py b/tractor/_forkserver_override.py index 07933dd..c515510 100644 --- a/tractor/_forkserver_override.py +++ b/tractor/_forkserver_override.py @@ -234,8 +234,8 @@ def main(listener_fd, alive_r, preload, main_path=None, sys_path=None): os.close(child_w) else: # This shouldn't happen really - warnings.warn('forkserver: waitpid returned ' - 'unexpected pid %d' % pid) + warnings.warning('forkserver: waitpid returned ' + 'unexpected pid %d' % pid) if listener in rfds: # Incoming fork request diff --git a/tractor/_trionics.py b/tractor/_trionics.py index aecf16e..203a9dc 100644 --- a/tractor/_trionics.py +++ b/tractor/_trionics.py @@ -275,7 +275,7 @@ async def open_nursery() -> typing.AsyncGenerator[ActorNursery, None]: # ria_nursery scope end # XXX: do we need a `trio.Cancelled` catch here as well? - except (Exception, trio.MultiError) as err: + except (Exception, trio.MultiError, trio.Cancelled) as err: # If actor-local error was raised while waiting on # ".run_in_actor()" actors then we also want to cancel all # remaining sub-actors (due to our lone strategy: