Use .shield() meth name from tractor

tina_free_vwap
Tyler Goodlet 2020-12-17 09:27:18 -05:00
parent a790a59962
commit 9aeb8603ac
1 changed files with 1 additions and 1 deletions

View File

@ -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: