Simplify ContextManager stuff

Author: DylanRussell

instrumentation-genai/opentelemetry-instrumentation-anthropic/src/opentelemetry/instrumentation/anthropic/patch.py

@@ -114,7 +114,7 @@ def _create_invocation(
     )
 
     server_address, server_port = get_server_address_and_port(instance)
-    invocation = handler.start_inference(
+    invocation = handler.inference(
         provider=ANTHROPIC,
         request_model=request_model,
         server_address=server_address,

util/opentelemetry-util-genai/CHANGELOG.md

@@ -13,7 +13,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Apply attribute for sampling on instantiation of all invocation types.
   ([#4553](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/4553))
 - Minor code cleanup and changes in preparation of moving google's GenAI instrumentation
-  library to use this util library ([#4556](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/4556))
+  library to use this util library ([#4556](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/4556), [#4570](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/4570))
 
 ## Version 0.4b0 (2026-05-01)
 

util/opentelemetry-util-genai/src/opentelemetry/util/genai/_invocation.py

@@ -5,12 +5,12 @@
 
 import timeit
 from abc import ABC, abstractmethod
-from contextlib import contextmanager
 from contextvars import Token
 from dataclasses import asdict
-from typing import TYPE_CHECKING, Any, Iterator, Sequence
+from types import TracebackType
+from typing import TYPE_CHECKING, Any, Sequence
 
-from typing_extensions import Self, TypeAlias
+from typing_extensions import TypeAlias
 
 from opentelemetry._logs import Logger, LogRecord
 from opentelemetry.context import Context, attach, detach
@@ -138,6 +138,20 @@ def _call_completion_hook(
             log_record=log_record,
         )
 
+    def __enter__(self):
+        return self
+
+    def __exit__(
+        self,
+        type_: type[BaseException] | None,
+        value: BaseException | None,
+        traceback: TracebackType | None,
+    ) -> None:
+        if value:
+            self.fail(value)
+            raise
+        self.stop()
+
     @abstractmethod
     def _apply_finish(self, error: Error | None = None) -> None:
         """Apply finish telemetry (attributes, metrics, events)."""
@@ -165,16 +179,6 @@ def fail(self, error: Error | BaseException) -> None:
             error = Error(type=type(error), message=str(error))
         self._finish(error)
 
-    @contextmanager
-    def _managed(self) -> Iterator[Self]:
-        """Context manager that calls stop() on success or fail() on exception."""
-        try:
-            yield self
-        except Exception as exc:
-            self.fail(exc)
-            raise
-        self.stop()
-
 
 def get_content_attributes(
     *,