diff --git a/piker/data/_sampling.py b/piker/data/_sampling.py
index 1a410309..edba3e1f 100644
--- a/piker/data/_sampling.py
+++ b/piker/data/_sampling.py
@@ -331,7 +331,6 @@ async def sample_and_broadcast(
             lags: int = 0
 
             for (stream, ctx, tick_throttle) in subs:
-
                 try:
                     with trio.move_on_after(0.2) as cs:
                         if tick_throttle:
diff --git a/piker/data/_source.py b/piker/data/_source.py
index 9f0b35b0..87ba74a3 100644
--- a/piker/data/_source.py
+++ b/piker/data/_source.py
@@ -23,7 +23,8 @@ import decimal
 
 from bidict import bidict
 import numpy as np
-from msgspec import Struct
+
+from .types import Struct
 # from numba import from_dtype