@@ -137,7 +137,9 @@ def _extract_messages_v2(messages):
137137 result = []
138138 for msg in messages :
139139 role = msg ["role" ] if isinstance (msg , dict ) else getattr (msg , "role" , "unknown" )
140- content = msg ["content" ] if isinstance (msg , dict ) else getattr (msg , "content" , "" )
140+ content = (
141+ msg ["content" ] if isinstance (msg , dict ) else getattr (msg , "content" , "" )
142+ )
141143 result .append ({"role" : role , "content" : transform_message_content (content )})
142144 return result
143145
@@ -165,7 +167,9 @@ def _append_stream_delta_text(collected_text, event):
165167def _collect_v2_stream_end_fields (span , event , include_pii , collected_text ):
166168 # type: (Span, Any, bool, list[str]) -> None
167169 if include_pii and collected_text :
168- set_data_normalized (span , SPANDATA .GEN_AI_RESPONSE_TEXT , ["" .join (collected_text )])
170+ set_data_normalized (
171+ span , SPANDATA .GEN_AI_RESPONSE_TEXT , ["" .join (collected_text )]
172+ )
169173 set_span_data_from_sources (
170174 span , event , STREAM_CHAT_RESPONSE_SOURCES , require_truthy = False
171175 )
0 commit comments