@@ -160,17 +160,22 @@ private async Task ProcessStreamAsync(PipeReader reader, PipeWriter writer, Acti
160160 {
161161 Logger . LogError ( ex , "Failed to parse JSON from SSE event for transformer {TransformerType}. EventType: {EventType}, Data: {Data}" ,
162162 GetType ( ) . Name , sseEvent . EventType , sseEvent . Data ) ;
163+ var commonTags = new ActivityTagsCollection ( [
164+ new KeyValuePair < string , object ? > ( "sse.type" , sseEvent . EventType ) ,
165+ new KeyValuePair < string , object ? > ( "sse.data" , sseEvent . Data )
166+ ] ) ;
163167
164168 // Add error event to activity for JSON parsing failures
165169 _ = activity ? . AddEvent (
166170 new ActivityEvent (
167- "Failed to parse JSON" ,
171+ name : "Failed to parse JSON" ,
168172 timestamp : DateTimeOffset . UtcNow ,
169- [ new KeyValuePair < string , object ? > ( "sse.type" , sseEvent . EventType ) ]
173+ commonTags
170174 )
171175 ) ;
172176 _ = activity ? . SetStatus ( ActivityStatusCode . Error , "Failed to parse JSON from SSE event" ) ;
173- _ = activity ? . AddException ( ex , [ new KeyValuePair < string , object ? > ( "sse.type" , sseEvent . EventType ) ] ) ;
177+ _ = activity ? . AddException ( ex ) ;
178+ throw ; // Re-throw to be handled by caller
174179 }
175180
176181 if ( transformedEvent == null )
0 commit comments