From 51170f3cf37b7dcb45d9ed9898a18127a7060b68 Mon Sep 17 00:00:00 2001
From: Ruben Fiszel <ruben@windmill.dev>
Date: Mon, 26 Jan 2026 11:21:03 +0000
Subject: [PATCH] better sse break

---
 backend/windmill-worker/src/ai/sse.rs | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/backend/windmill-worker/src/ai/sse.rs b/backend/windmill-worker/src/ai/sse.rs
index 4c08a2e40c..cbc4da9580 100644
--- a/backend/windmill-worker/src/ai/sse.rs
+++ b/backend/windmill-worker/src/ai/sse.rs
@@ -75,7 +75,10 @@ pub trait SSEParser {
                             "Breaking SSE stream after {} consecutive parsing errors",
                             consecutive_errors
                         );
-                        break;
+                        return Err(Error::InternalErr(format!(
+                            "SSE stream terminated after {} consecutive parsing errors",
+                            consecutive_errors
+                        )));
                     }
                 }
             }