diff --git a/app/routers/runs.py b/app/routers/runs.py
index 6a36abe..53c4540 100644
--- a/app/routers/runs.py
+++ b/app/routers/runs.py
@@ -1152,6 +1152,13 @@ async def get_ipfs_stream_info(run_id: str, request: Request):
 
     # Try to get pending run to find the Celery task ID
     pending = await database.get_pending_run(run_id)
+    from fastapi.responses import JSONResponse
+    no_cache_headers = {
+        "Cache-Control": "no-cache, no-store, must-revalidate",
+        "Pragma": "no-cache",
+        "Expires": "0"
+    }
+
     if not pending:
         # Try completed runs
         run = await database.get_run_cache(run_id)
@@ -1161,11 +1168,14 @@ async def get_ipfs_stream_info(run_id: str, request: Request):
         ipfs_cid = run.get("ipfs_cid")
         if ipfs_cid:
             gateway = os.environ.get("IPFS_GATEWAY_URL", "https://ipfs.io/ipfs")
-            return {
-                "run_id": run_id,
-                "status": "completed",
-                "ipfs_video_url": f"{gateway}/{ipfs_cid}",
-            }
+            return JSONResponse(
+                content={
+                    "run_id": run_id,
+                    "status": "completed",
+                    "ipfs_video_url": f"{gateway}/{ipfs_cid}",
+                },
+                headers=no_cache_headers
+            )
         raise HTTPException(404, "No IPFS stream info available")
 
     task_id = pending.get("celery_task_id")
@@ -1175,6 +1185,14 @@ async def get_ipfs_stream_info(run_id: str, request: Request):
     # Get the Celery task result
     result = celery_app.AsyncResult(task_id)
 
+    from fastapi.responses import JSONResponse
+    gateway = os.environ.get("IPFS_GATEWAY_URL", "https://ipfs.io/ipfs")
+    no_cache_headers = {
+        "Cache-Control": "no-cache, no-store, must-revalidate",
+        "Pragma": "no-cache",
+        "Expires": "0"
+    }
+
     if result.ready():
         # Task is complete - check the result for IPFS playlist info
         task_result = result.result
@@ -1182,17 +1200,37 @@ async def get_ipfs_stream_info(run_id: str, request: Request):
             ipfs_playlist_cid = task_result.get("ipfs_playlist_cid")
             ipfs_playlist_url = task_result.get("ipfs_playlist_url")
             if ipfs_playlist_url:
-                return {
-                    "run_id": run_id,
-                    "status": "completed",
-                    "ipfs_playlist_cid": ipfs_playlist_cid,
-                    "ipfs_playlist_url": ipfs_playlist_url,
-                    "segment_count": task_result.get("ipfs_segment_count", 0),
-                }
+                return JSONResponse(
+                    content={
+                        "run_id": run_id,
+                        "status": "completed",
+                        "ipfs_playlist_cid": ipfs_playlist_cid,
+                        "ipfs_playlist_url": ipfs_playlist_url,
+                        "segment_count": task_result.get("ipfs_segment_count", 0),
+                    },
+                    headers=no_cache_headers
+                )
 
-    # Task is still running or no IPFS info available
-    return {
+    # Task is still running - check database for live playlist updates
+    ipfs_playlist_cid = pending.get("ipfs_playlist_cid")
+
+    response_data = {
         "run_id": run_id,
         "status": pending.get("status", "pending"),
-        "message": "IPFS streaming info not yet available"
     }
+
+    if ipfs_playlist_cid:
+        response_data["ipfs_playlist_cid"] = ipfs_playlist_cid
+        response_data["ipfs_playlist_url"] = f"{gateway}/{ipfs_playlist_cid}"
+    else:
+        response_data["message"] = "IPFS streaming info not yet available"
+
+    # No caching for live streaming data
+    return JSONResponse(
+        content=response_data,
+        headers={
+            "Cache-Control": "no-cache, no-store, must-revalidate",
+            "Pragma": "no-cache",
+            "Expires": "0"
+        }
+    )