|
14 | 14 |
|
15 | 15 | """OpenTelemetry Vertex AI instrumentation""" |
16 | 16 |
|
17 | | -from functools import partial |
18 | 17 | import logging |
19 | 18 | import types |
| 19 | +from functools import partial |
20 | 20 | from typing import Collection, Optional |
21 | 21 |
|
22 | 22 | from wrapt import wrap_function_wrapper |
23 | 23 |
|
24 | 24 | from opentelemetry._events import ( |
25 | 25 | EventLogger, |
26 | 26 | EventLoggerProvider, |
27 | | - Event, |
28 | 27 | get_event_logger, |
29 | 28 | ) |
30 | 29 | from opentelemetry.instrumentation.instrumentor import BaseInstrumentor |
@@ -311,19 +310,6 @@ def _handle_response(span, event_logger: EventLogger, response, llm_model): |
311 | 310 | span.set_status(Status(StatusCode.OK)) |
312 | 311 |
|
313 | 312 |
|
314 | | -def _with_tracer_wrapper(func): |
315 | | - """Helper for providing tracer for wrapper functions.""" |
316 | | - |
317 | | - def _with_tracer(tracer, to_wrap): |
318 | | - def wrapper(wrapped, instance, args, kwargs): |
319 | | - return func(tracer, to_wrap, wrapped, instance, args, kwargs) |
320 | | - |
321 | | - return wrapper |
322 | | - |
323 | | - return _with_tracer |
324 | | - |
325 | | - |
326 | | -# @_with_tracer_wrapper |
327 | 313 | async def _awrap( |
328 | 314 | tracer, event_logger: EventLogger, to_wrap, wrapped, instance, args, kwargs |
329 | 315 | ): |
@@ -372,7 +358,6 @@ async def _awrap( |
372 | 358 | return response |
373 | 359 |
|
374 | 360 |
|
375 | | -# @_with_tracer_wrapper |
376 | 361 | def _wrap( |
377 | 362 | tracer, event_logger: EventLogger, to_wrap, wrapped, instance, args, kwargs |
378 | 363 | ): |
|
0 commit comments