Wrap sends in a separate nursery

andersea · Jan 26, 2024 · 7270155 · 7270155
1 parent 9d862bb
commit 7270155
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/slurry/_pipeline.py b/slurry/_pipeline.py
@@ -59,8 +59,9 @@ async def _pump(self):
                     if not self._taps:
                         # Hmm.. Debatable. Should closing all taps close the pipeline?
                         break
-                    for tap in self._taps:
-                        nursery.start_soon(tap.send, item)
+                    async with trio.open_nursery() as send_nursery:
+                        for tap in self._taps:
+                            send_nursery.start_soon(tap.send, item)
 
         # There is no more output to send. Close the taps.
         for tap in self._taps: