From e6dd6e851c5f13d2d1e3325678ceb11268e76067 Mon Sep 17 00:00:00 2001 From: giles Date: Mon, 2 Feb 2026 23:34:08 +0000 Subject: [PATCH] Add debug logging for CID video source resolution Co-Authored-By: Claude Opus 4.5 --- tasks/streaming.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/tasks/streaming.py b/tasks/streaming.py index ea4128e..e5a7c45 100644 --- a/tasks/streaming.py +++ b/tasks/streaming.py @@ -96,10 +96,12 @@ class CIDVideoSource: def _ensure_source(self): if self._source is None: + logger.info(f"CIDVideoSource._ensure_source: resolving cid={self.cid} with actor_id={self.actor_id}") path = resolve_asset(self.cid, self.actor_id) if not path: - raise ValueError(f"Could not resolve video source: {self.cid}") + 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 @@ -172,9 +174,11 @@ def create_cid_primitives(actor_id: Optional[str] = None): Returns dict of primitives that resolve CIDs before creating sources. """ def prim_make_video_source_cid(cid: str, fps: float = 30): + logger.info(f"CID-aware make-video-source called: cid={cid}, fps={fps}, actor_id={actor_id}") return CIDVideoSource(cid, fps, actor_id) def prim_make_audio_analyzer_cid(cid: str): + logger.info(f"CID-aware make-audio-analyzer called: cid={cid}, actor_id={actor_id}") return CIDAudioAnalyzer(cid, actor_id) return {