diff --git a/piker/brokers/binance/feed.py b/piker/brokers/binance/feed.py index efe2f717..b7d68edb 100644 --- a/piker/brokers/binance/feed.py +++ b/piker/brokers/binance/feed.py @@ -448,7 +448,6 @@ async def subscribe( async def stream_quotes( - send_chan: trio.abc.SendChannel, symbols: list[str], feed_is_live: trio.Event, @@ -460,6 +459,7 @@ async def stream_quotes( ) -> None: async with ( + tractor.trionics.maybe_raise_from_masking_exc(), send_chan as send_chan, open_cached_client('binance') as client, ):