Skip to content

Commit 10a4672

Browse files
committed
fix: improve SSE parsing error visibility and propagation
1 parent a22a368 commit 10a4672

1 file changed

Lines changed: 16 additions & 4 deletions

File tree

src/cortex-engine/src/client/cortex.rs

Lines changed: 16 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -667,11 +667,23 @@ impl ModelClient for CortexClient {
667667
}
668668
}
669669
Err(e) => {
670-
tracing::debug!(
671-
"Failed to parse Cortex event: {} - {}",
672-
e,
673-
event.data
670+
let data_preview = if event.data.len() > 100 {
671+
&event.data[..100]
672+
} else {
673+
&event.data
674+
};
675+
tracing::warn!(
676+
error = %e,
677+
data_preview = %data_preview,
678+
"Failed to parse SSE event"
679+
);
680+
let error_msg = format!(
681+
"SSE parsing error: {} (data: {})",
682+
e, data_preview
674683
);
684+
if tx.send(Ok(ResponseEvent::Error(error_msg))).await.is_err() {
685+
break;
686+
}
675687
}
676688
}
677689
}

0 commit comments

Comments
 (0)