diff --git a/agentlightning/instrumentation/weave.py b/agentlightning/instrumentation/weave.py index e75de0b72..6b16dbf55 100644 --- a/agentlightning/instrumentation/weave.py +++ b/agentlightning/instrumentation/weave.py @@ -303,8 +303,10 @@ def evaluation_status(self, req: tsi.EvaluationStatusReq) -> tsi.EvaluationStatu # --- OTEL API --- - def otel_export(self, req: tsi.OtelExportReq) -> tsi.OtelExportRes: - return tsi.OtelExportRes() + def otel_export(self, req: Any) -> Any: + # OtelExportReq/OtelExportRes were removed from tsi in newer weave versions. + # Use Any to maintain backward compatibility across weave releases. + return None # ========================================== # Object Interface (V2 APIs) @@ -465,6 +467,13 @@ def trace_usage(self, *args: Any, **kwargs: Any) -> Any: def calls_usage(self, *args: Any, **kwargs: Any) -> Any: raise NotImplementedError() + # Methods added in newer weave releases to satisfy the abstract interface. + def annotation_queue_delete(self, *args: Any, **kwargs: Any) -> Any: + raise NotImplementedError() + + def eval_results_query(self, *args: Any, **kwargs: Any) -> Any: + raise NotImplementedError() + # Module-level storage for originals _original_init_weave_get_server: Callable[..., Any] | None = None