diff --git a/tasks/streaming.py b/tasks/streaming.py
index 189881a..9ee9800 100644
--- a/tasks/streaming.py
+++ b/tasks/streaming.py
@@ -23,6 +23,8 @@ from cache_manager import get_cache_manager
 
 logger = logging.getLogger(__name__)
 
+# Debug: verify module is being loaded
+print(f"DEBUG MODULE LOAD: tasks/streaming.py loaded at {__file__}", file=sys.stderr)
 
 # Module-level event loop for database operations
 _resolve_loop = None