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
+                        )));
                     }
                 }
             }