File tree Expand file tree Collapse file tree 1 file changed +10
-10
lines changed
instrumentation-genai/opentelemetry-instrumentation-vertexai/src/opentelemetry/instrumentation/vertexai Expand file tree Collapse file tree 1 file changed +10
-10
lines changed Original file line number Diff line number Diff line change @@ -172,6 +172,9 @@ def handle_response(
172172 | prediction_service_v1beta1 .GenerateContentResponse
173173 | None ,
174174 ) -> None :
175+ event = LogRecord (
176+ event_name = "gen_ai.client.inference.operation.details" ,
177+ )
175178 attributes = (
176179 get_server_attributes (instance .api_endpoint ) # type: ignore[reportUnknownMemberType]
177180 | request_attributes
@@ -203,6 +206,13 @@ def handle_response(
203206 )
204207 for candidate in response .candidates
205208 ]
209+ self .completion_hook .on_completion (
210+ inputs = inputs ,
211+ outputs = outputs ,
212+ system_instruction = system_instructions ,
213+ span = span ,
214+ log_record = event ,
215+ )
206216 content_attributes = {
207217 k : [asdict (x ) for x in v ]
208218 for k , v in [
@@ -227,23 +237,13 @@ def handle_response(
227237 for k , v in content_attributes .items ()
228238 }
229239 )
230- event = LogRecord (
231- event_name = "gen_ai.client.inference.operation.details" ,
232- )
233240 event .attributes = attributes
234241 if capture_content in (
235242 ContentCapturingMode .SPAN_AND_EVENT ,
236243 ContentCapturingMode .EVENT_ONLY ,
237244 ):
238245 event .attributes |= content_attributes
239246 self .logger .emit (event )
240- self .completion_hook .on_completion (
241- inputs = inputs ,
242- outputs = outputs ,
243- system_instruction = system_instructions ,
244- span = span ,
245- log_record = event ,
246- )
247247
248248 yield handle_response
249249
You can’t perform that action at this time.
0 commit comments