diff --git a/piker/clearing/_ems.py b/piker/clearing/_ems.py
index 06ae3b70..8d6ba868 100644
--- a/piker/clearing/_ems.py
+++ b/piker/clearing/_ems.py
@@ -172,6 +172,7 @@ async def clear_dark_triggers(
     # TODO:
     # - numba all this!
     # - this stream may eventually contain multiple symbols
+    quote_stream._raise_on_lag = False
     async for quotes in quote_stream:
         # start = time.time()
         for sym, quote in quotes.items():