move into resample function

MSeal · Oct 30, 2023 · 41437d7 · 41437d7
1 parent 07cba57
commit 41437d7
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/src/dx/comms/resample.py b/src/dx/comms/resample.py
@@ -1,8 +1,5 @@
 import structlog
 
-from dx.filtering import handle_resample
-from dx.types.filters import DEXResampleMessage
-
 logger = structlog.get_logger(__name__)
 
 
@@ -20,7 +17,10 @@ def _recv(msg):
     comm.send({"status": "connected", "source": "resampler"})
 
 
-def handle_resample_comm(msg):
+def handle_resample_comm(msg: dict) -> None:
+    from dx.filtering import handle_resample
+    from dx.types.filters import DEXResampleMessage
+
     data = msg.get("content", {}).get("data", {})
     if not data:
         return