diff --git a/piker/brokers/kraken.py b/piker/brokers/kraken.py index ac80988b..3620f19a 100644 --- a/piker/brokers/kraken.py +++ b/piker/brokers/kraken.py @@ -467,7 +467,7 @@ async def stream_quotes( ws_pairs = {} sym_infos = {} - async with open_cached_client('kraken') as client: + async with open_cached_client('kraken') as client, send_chan as send_chan: # keep client cached for real-time section for sym in symbols: