Use .shield_channel() meth name from tractor

vwap_backup
Tyler Goodlet 2020-12-17 09:27:18 -05:00
parent 82c99c5fee
commit d01ca0bf96
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_channel():
async for quotes in stream:
for symbol, quotes in quotes.items():
if symbol == sym: