Addressing instrumentation concern

Author: akshaylive

src/uipath/runtime/base.py

@@ -11,9 +11,6 @@
 )
 
 from opentelemetry import trace
-from opentelemetry.instrumentation.instrumentor import (  # type: ignore[attr-defined]
-    BaseInstrumentor,
-)
 from typing_extensions import override
 from uipath.core import UiPathTraceManager
 
@@ -101,10 +98,6 @@ async def stream(
         # Without it, the function wouldn't match the AsyncGenerator return type
         yield
 
-    def get_instrumentor(self) -> Optional[BaseInstrumentor]:
-        """Get instrumentor for this runtime. If no instrumentor is available, return None."""
-        return None
-
     @abstractmethod
     async def cleanup(self):
         """Cleaup runtime resources."""
@@ -138,15 +131,12 @@ async def execute(
         input: dict[str, Any],
     ) -> UiPathRuntimeResult:
         """Execute runtime with context."""
-        instrumentor = self.delegate.get_instrumentor()
         if self.log_handler:
             log_interceptor = UiPathRuntimeLogsInterceptor(
                 execution_id=self.execution_id, log_handler=self.log_handler
             )
             log_interceptor.setup()
 
-        if instrumentor is not None:
-            instrumentor.instrument(tracer_provider=self.trace_manager.tracer_provider)
         try:
             if self.execution_id:
                 with self.trace_manager.start_execution_span(
@@ -157,8 +147,6 @@ async def execute(
                 return await self.delegate.execute(input)
         finally:
             self.trace_manager.flush_spans()
-            if instrumentor is not None:
-                instrumentor.uninstrument()
             if self.log_handler:
                 log_interceptor.teardown()
 
@@ -179,9 +167,6 @@ async def stream(
         Raises:
             UiPathRuntimeStreamNotSupportedError: If the runtime doesn't support streaming
         """
-        instrumentor = self.delegate.get_instrumentor()
-        if instrumentor is not None:
-            instrumentor.instrument(tracer_provider=self.trace_manager.tracer_provider)
         try:
             tracer = trace.get_tracer("uipath-runtime")
             span_attributes: dict[str, Any] = {}
@@ -194,8 +179,6 @@ async def stream(
                     yield event
         finally:
             self.trace_manager.flush_spans()
-            if instrumentor is not None:
-                instrumentor.uninstrument()
 
     def cleanup(self) -> None:
         """Close runtime resources."""