From 487acdd6069dfba1efe5fa787819ec6a7dcbc140 Mon Sep 17 00:00:00 2001
From: giles <giles.bradshaw@sigyl.com>
Date: Tue, 3 Feb 2026 00:16:49 +0000
Subject: [PATCH] Fix global declaration placement in streaming task

---
 tasks/streaming.py | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/tasks/streaming.py b/tasks/streaming.py
index fa0adbc..769aaf7 100644
--- a/tasks/streaming.py
+++ b/tasks/streaming.py
@@ -240,6 +240,7 @@ def run_stream(
     Returns:
         Dict with output_cid, output_path, and status
     """
+    global _resolve_loop, _db_initialized
     task_id = self.request.id
     logger.info(f"Starting stream task {task_id} for run {run_id}")
 
@@ -330,7 +331,6 @@ def run_stream(
             logger.info(f"Stream output cached: CID={cached_file.cid}, IPFS={ipfs_cid}")
 
             # Save to database - reuse the module-level loop to avoid pool conflicts
-            global _resolve_loop, _db_initialized
             import asyncio
             import database
 
@@ -379,7 +379,6 @@ def run_stream(
             }
         else:
             # Update pending run status to failed - reuse module loop
-            global _resolve_loop, _db_initialized
             import asyncio
             import database
 
@@ -412,7 +411,6 @@ def run_stream(
         traceback.print_exc()
 
         # Update pending run status to failed - reuse module loop
-        global _resolve_loop, _db_initialized
         import asyncio
         import database