forked from goodboy/tractor
Drop remaining warn()s
parent
f60321a35a
commit
02a9cac557
|
@ -234,8 +234,8 @@ def main(listener_fd, alive_r, preload, main_path=None, sys_path=None):
|
||||||
os.close(child_w)
|
os.close(child_w)
|
||||||
else:
|
else:
|
||||||
# This shouldn't happen really
|
# This shouldn't happen really
|
||||||
warnings.warn('forkserver: waitpid returned '
|
warnings.warning('forkserver: waitpid returned '
|
||||||
'unexpected pid %d' % pid)
|
'unexpected pid %d' % pid)
|
||||||
|
|
||||||
if listener in rfds:
|
if listener in rfds:
|
||||||
# Incoming fork request
|
# Incoming fork request
|
||||||
|
|
|
@ -275,7 +275,7 @@ async def open_nursery() -> typing.AsyncGenerator[ActorNursery, None]:
|
||||||
# ria_nursery scope end
|
# ria_nursery scope end
|
||||||
|
|
||||||
# XXX: do we need a `trio.Cancelled` catch here as well?
|
# 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
|
# If actor-local error was raised while waiting on
|
||||||
# ".run_in_actor()" actors then we also want to cancel all
|
# ".run_in_actor()" actors then we also want to cancel all
|
||||||
# remaining sub-actors (due to our lone strategy:
|
# remaining sub-actors (due to our lone strategy:
|
||||||
|
|
Loading…
Reference in New Issue