From c5c7e694ecfa44a3205daeb9c80684ecca38472f Mon Sep 17 00:00:00 2001
From: Tyler Goodlet <jgbt@protonmail.com>
Date: Sun, 1 Aug 2021 13:10:51 -0400
Subject: [PATCH 1/4] Better early timeout handling, continue on child re-lock

---
 tests/test_debugger.py | 20 ++++++++------------
 1 file changed, 8 insertions(+), 12 deletions(-)

diff --git a/tests/test_debugger.py b/tests/test_debugger.py
index a3eb040..87bce1b 100644
--- a/tests/test_debugger.py
+++ b/tests/test_debugger.py
@@ -422,27 +422,22 @@ def test_multi_nested_subactors_error_through_nurseries(spawn):
 
     child = spawn('multi_nested_subactors_error_up_through_nurseries')
 
+    timed_out_early: bool = False
+
     for i in range(12):
         try:
             child.expect(r"\(Pdb\+\+\)")
             child.sendline('c')
             time.sleep(0.1)
 
-        except (
-            pexpect.exceptions.EOF,
-            pexpect.exceptions.TIMEOUT,
-        ):
-            # races all over..
-
-            print(f"Failed early on {i}?")
-            before = str(child.before.decode())
-
-            timed_out_early = True
+        except pexpect.exceptions.EOF:
 
             # race conditions on how fast the continue is sent?
+            print(f"Failed early on {i}?")
+            timed_out_early = True
             break
-
-    child.expect(pexpect.EOF)
+    else:
+        child.expect(pexpect.EOF)
 
     if not timed_out_early:
         before = str(child.before.decode())
@@ -499,6 +494,7 @@ def test_root_nursery_cancels_before_child_releases_tty_lock(
             child.expect(pexpect.EOF)
             break
         except pexpect.exceptions.TIMEOUT:
+            child.sendline('c')
             print('child was able to grab tty lock again?')
 
     if not timed_out_early:

From 82999801a6824c5aeee8f67b852dc48fc8141f81 Mon Sep 17 00:00:00 2001
From: Tyler Goodlet <jgbt@protonmail.com>
Date: Mon, 2 Aug 2021 16:35:26 -0400
Subject: [PATCH 2/4] Drop leftover noisy exception logging..

---
 tractor/_trionics.py | 1 -
 1 file changed, 1 deletion(-)

diff --git a/tractor/_trionics.py b/tractor/_trionics.py
index 2eb64d1..5b58511 100644
--- a/tractor/_trionics.py
+++ b/tractor/_trionics.py
@@ -281,7 +281,6 @@ async def _open_and_supervise_one_cancels_all_nursery(
                     # Instead try to wait for pdb to be released before
                     # tearing down.
                     if is_root_process():
-                        log.exception(f"we're root with {err}")
 
                         # TODO: could this make things more deterministic?
                         # wait to see if a sub-actor task will be

From 7431e8ea0166e32e08c3d6b0696cf0c50e149514 Mon Sep 17 00:00:00 2001
From: Tyler Goodlet <jgbt@protonmail.com>
Date: Mon, 2 Aug 2021 20:37:27 -0400
Subject: [PATCH 3/4] Don't log cancelled inceptions seen by the root

---
 tractor/_root.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/tractor/_root.py b/tractor/_root.py
index bfaaf4f..9eba909 100644
--- a/tractor/_root.py
+++ b/tractor/_root.py
@@ -17,6 +17,7 @@ from . import _spawn
 from . import _state
 from . import log
 from ._ipc import _connect_chan
+from ._exceptions import is_multi_cancelled
 
 
 # set at startup and after forks
@@ -177,7 +178,7 @@ async def open_root_actor(
 
                 entered = await _debug._maybe_enter_pm(err)
 
-                if not entered:
+                if not entered and not is_multi_cancelled(err):
                     logger.exception("Root actor crashed:")
 
                 # always re-raise

From ace1b1312c953166f4507a4802e9b6af1debd77d Mon Sep 17 00:00:00 2001
From: Tyler Goodlet <jgbt@protonmail.com>
Date: Mon, 2 Aug 2021 21:49:15 -0400
Subject: [PATCH 4/4] Terminate async gen example caller to avoid (benign)
 errors in console output

---
 examples/asynchronous_generators.py | 40 +++++++++++++++--------------
 1 file changed, 21 insertions(+), 19 deletions(-)

diff --git a/examples/asynchronous_generators.py b/examples/asynchronous_generators.py
index 99b0a13..b037b08 100644
--- a/examples/asynchronous_generators.py
+++ b/examples/asynchronous_generators.py
@@ -1,39 +1,41 @@
+from typing import AsyncIterator
 from itertools import repeat
+
 import trio
 import tractor
 
-tractor.log.get_console_log("INFO")
 
+async def stream_forever() -> AsyncIterator[int]:
 
-async def stream_forever():
     for i in repeat("I can see these little future bubble things"):
-        # each yielded value is sent over the ``Channel`` to the
-        # parent actor
+        # each yielded value is sent over the ``Channel`` to the parent actor
         yield i
         await trio.sleep(0.01)
 
 
 async def main():
 
-    # stream for at most 1 seconds
-    with trio.move_on_after(1) as cancel_scope:
+    async with tractor.open_nursery() as n:
 
-        async with tractor.open_nursery() as n:
+        portal = await n.start_actor(
+            'donny',
+            enable_modules=[__name__],
+        )
 
-            portal = await n.start_actor(
-                'donny',
-                enable_modules=[__name__],
-            )
+        # this async for loop streams values from the above
+        # async generator running in a separate process
+        async with portal.open_stream_from(stream_forever) as stream:
+            count = 0
+            async for letter in stream:
+                print(letter)
+                count += 1
 
-            # this async for loop streams values from the above
-            # async generator running in a separate process
-            async with portal.open_stream_from(stream_forever) as stream:
-                async for letter in stream:
-                    print(letter)
+                if count > 50:
+                    break
 
-    # we support trio's cancellation system
-    assert cancel_scope.cancelled_caught
-    assert n.cancelled
+        print('stream terminated')
+
+        await portal.cancel_actor()
 
 
 if __name__ == '__main__':