From 8a768af5bb24f4a998962401af6f0f75995641d8 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Thu, 24 Apr 2025 10:37:33 -0400 Subject: [PATCH] Update legacy type to `tractor.MsgStream` --- piker/clearing/_ems.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/piker/clearing/_ems.py b/piker/clearing/_ems.py index e39c9cdc..aad849aa 100644 --- a/piker/clearing/_ems.py +++ b/piker/clearing/_ems.py @@ -161,7 +161,7 @@ async def clear_dark_triggers( router: Router, brokerd_orders_stream: tractor.MsgStream, - quote_stream: tractor.ReceiveMsgStream, # noqa + quote_stream: tractor.MsgStream, broker: str, fqme: str, @@ -177,6 +177,7 @@ async def clear_dark_triggers( ''' # XXX: optimize this for speed! # TODO: + # - port to the new ringbuf stuff in `tractor.ipc`! # - numba all this! # - this stream may eventually contain multiple symbols quote_stream._raise_on_lag = False