Add preview warning for entry points

Author: jeremydvoss

sdk/monitor/azure-monitor-opentelemetry/CHANGELOG.md

@@ -10,6 +10,8 @@
     ([#31740](https://github.com/Azure/azure-sdk-for-python/pull/31740))
 - Un-vendoring instrumentations
     ([#31744](https://github.com/Azure/azure-sdk-for-python/pull/31740))
+- Add preview warning for Autoinstrumentation entry points
+    ([#31767](https://github.com/Azure/azure-sdk-for-python/pull/31767))
 
 ### Breaking Changes
 

sdk/monitor/azure-monitor-opentelemetry/azure/monitor/opentelemetry/autoinstrumentation/__init__.py

@@ -3,3 +3,11 @@
 # Licensed under the MIT License. See License in the project root for
 # license information.
 # -------------------------------------------------------------------------
+
+from os.path import isdir
+
+_PREVIEW_ENTRY_POINT_WARNING = "OpenTelemetry Autoinstrumentation is in preview."
+
+
+def _is_attach_enabled():
+    return isdir("/agents/python/")

sdk/monitor/azure-monitor-opentelemetry/azure/monitor/opentelemetry/autoinstrumentation/_configurator.py

@@ -6,9 +6,14 @@
 
 
 import logging
+from warnings import warn
 
 from opentelemetry.sdk._configuration import _OTelSDKConfigurator
 
+from azure.monitor.opentelemetry.autoinstrumentation import (
+    _is_attach_enabled,
+    _PREVIEW_ENTRY_POINT_WARNING,
+)
 from azure.monitor.opentelemetry.diagnostics._diagnostic_logging import (
     AzureDiagnosticLogging,
 )
@@ -18,6 +23,9 @@
 
 class AzureMonitorConfigurator(_OTelSDKConfigurator):
     def _configure(self, **kwargs):
+        if not _is_attach_enabled():
+            # raise Warning(_PREVIEW_ENTRY_POINT_WARNING)
+            warn(_PREVIEW_ENTRY_POINT_WARNING)
         try:
             AzureDiagnosticLogging.enable(_logger)
             super()._configure(**kwargs)

sdk/monitor/azure-monitor-opentelemetry/azure/monitor/opentelemetry/autoinstrumentation/_distro.py

@@ -5,6 +5,7 @@
 # --------------------------------------------------------------------------
 import logging
 from os import environ
+from warnings import warn
 
 from opentelemetry.environment_variables import (
     OTEL_LOGS_EXPORTER,
@@ -20,6 +21,10 @@
 
 from azure.core.settings import settings
 from azure.core.tracing.ext.opentelemetry_span import OpenTelemetrySpan
+from azure.monitor.opentelemetry.autoinstrumentation import (
+    _is_attach_enabled,
+    _PREVIEW_ENTRY_POINT_WARNING,
+)
 from azure.monitor.opentelemetry.diagnostics._diagnostic_logging import (
     AzureDiagnosticLogging,
 )
@@ -37,6 +42,8 @@
 
 class AzureMonitorDistro(BaseDistro):
     def _configure(self, **kwargs) -> None:
+        if not _is_attach_enabled():
+            warn(_PREVIEW_ENTRY_POINT_WARNING)
         try:
             _configure_auto_instrumentation()
         except Exception as ex:

sdk/monitor/azure-monitor-opentelemetry/tests/autoinstrumentation/test_distro.py

@@ -1,3 +1,4 @@
+import warnings
 from unittest import TestCase
 from unittest.mock import patch
 
@@ -8,13 +9,30 @@
 
 
 class TestDistro(TestCase):
+    @patch("azure.monitor.opentelemetry.autoinstrumentation._distro._is_attach_enabled", return_value=True)
     @patch("azure.monitor.opentelemetry.autoinstrumentation._distro.settings")
     @patch(
         "azure.monitor.opentelemetry.autoinstrumentation._distro.AzureDiagnosticLogging.enable"
     )
-    def test_configure(self, mock_diagnostics, azure_core_mock):
+    def test_configure(self, mock_diagnostics, azure_core_mock, attach_mock):
         distro = AzureMonitorDistro()
-        distro.configure()
+        with warnings.catch_warnings():
+            warnings.simplefilter("error")
+            distro.configure()
+        self.assertEqual(mock_diagnostics.call_count, 2)
+        self.assertEqual(
+            azure_core_mock.tracing_implementation, OpenTelemetrySpan
+        )
+
+    @patch("azure.monitor.opentelemetry.autoinstrumentation._distro._is_attach_enabled", return_value=False)
+    @patch("azure.monitor.opentelemetry.autoinstrumentation._distro.settings")
+    @patch(
+        "azure.monitor.opentelemetry.autoinstrumentation._distro.AzureDiagnosticLogging.enable"
+    )
+    def test_configure_preview(self, mock_diagnostics, azure_core_mock, attach_mock):
+        distro = AzureMonitorDistro()
+        with self.assertWarns(Warning):
+            distro.configure()
         self.assertEqual(mock_diagnostics.call_count, 2)
         self.assertEqual(
             azure_core_mock.tracing_implementation, OpenTelemetrySpan