diff --git a/tasks/streaming.py b/tasks/streaming.py
index 11dad2a..f548212 100644
--- a/tasks/streaming.py
+++ b/tasks/streaming.py
@@ -112,7 +112,6 @@ class CIDVideoSource:
                 raise ValueError(f"Could not resolve video source '{self.cid}' for actor_id={self.actor_id}")
 
             logger.info(f"CIDVideoSource._ensure_source: resolved to path={path}")
-            from streaming.stream_sexp_generic import VideoSource
             # Import from primitives where VideoSource is defined
             from sexp_effects.primitive_libs.streaming import VideoSource
             self._source = VideoSource(str(path), self.fps)