Use .shield() meth name from tractor

2020-12-17 09:27:18 -05:00 · 2020-12-17 09:27:18 -05:00 · 48da729364
parent c01382294e
commit 48da729364
1 changed files with 1 additions and 1 deletions
--- a/piker/fsp/init.py
+++ b/piker/fsp/init.py
@ -113,7 +113,7 @@ async def cascade(
                stream,
            ):
                # task cancellation won't kill the channel
-                async with stream.shield():
+                with stream.shield():
                    async for quotes in stream:
                        for symbol, quotes in quotes.items():
                            if symbol == sym: