Added Otel flag

Author: gavin-aguiar

azure_functions_worker/constants.py

@@ -80,3 +80,6 @@
 
 # Base extension supported Python minor version
 BASE_EXT_SUPPORTED_PY_MINOR_VERSION = 8
+
+PYTHON_ENABLE_OPENTELEMETRY = "PYTHON_ENABLE_OPENTELEMETRY"
+PYTHON_ENABLE_OPENTELEMETRY_DEFAULT = True

azure_functions_worker/dispatcher.py

@@ -30,7 +30,8 @@
                         PYTHON_SCRIPT_FILE_NAME,
                         PYTHON_SCRIPT_FILE_NAME_DEFAULT,
                         PYTHON_LANGUAGE_RUNTIME, PYTHON_ENABLE_INIT_INDEXING,
-                        METADATA_PROPERTIES_WORKER_INDEXED)
+                        METADATA_PROPERTIES_WORKER_INDEXED, PYTHON_ENABLE_OPENTELEMETRY,
+                        PYTHON_ENABLE_OPENTELEMETRY_DEFAULT)
 from .extension import ExtensionManager
 from .http_v2 import http_coordinator, initialize_http_server, HttpV2Registry, \
     sync_http_request, HttpServerInitError
@@ -318,10 +319,12 @@ async def _handle__worker_init_request(self, request):
             constants.SHARED_MEMORY_DATA_TRANSFER: _TRUE,
         }
 
-        self.update_opentelemetry_status()
+        if get_app_setting(setting=PYTHON_ENABLE_OPENTELEMETRY,
+                           default_value=PYTHON_ENABLE_OPENTELEMETRY_DEFAULT):
+            self.update_opentelemetry_status()
 
-        if self._otel_libs_available:
-            capabilities[constants.WORKER_OPEN_TELEMETRY_ENABLED] = _TRUE
+            if self._otel_libs_available:
+                capabilities[constants.WORKER_OPEN_TELEMETRY_ENABLED] = _TRUE
 
         if DependencyManager.should_load_cx_dependencies():
             DependencyManager.prioritize_customer_dependencies()
@@ -708,9 +711,12 @@ async def _handle__function_environment_reload_request(self, request):
             bindings.load_binding_registry()
 
             capabilities = {}
-            self.update_opentelemetry_status()
-            if self._otel_libs_available:
-                capabilities[constants.WORKER_OPEN_TELEMETRY_ENABLED] = _TRUE
+            if get_app_setting(setting=PYTHON_ENABLE_OPENTELEMETRY,
+                               default_value=PYTHON_ENABLE_OPENTELEMETRY_DEFAULT):
+                self.update_opentelemetry_status()
+
+                if self._otel_libs_available:
+                    capabilities[constants.WORKER_OPEN_TELEMETRY_ENABLED] = _TRUE
 
             if is_envvar_true(PYTHON_ENABLE_INIT_INDEXING):
                 try: