Fix format errors

Author: rads-1996

sdk/monitor/azure-monitor-opentelemetry-exporter/azure/monitor/opentelemetry/exporter/_configuration/__init__.py

@@ -81,7 +81,7 @@ def _notify_callbacks(self, settings: Dict[str, str]):
             try:
                 cb(settings)
             except Exception as ex:  # pylint: disable=broad-except
-                logger.warning("Callback failed: %s", ex) # pylint: disable=do-not-log-exceptions-if-not-debug
+                logger.warning("Callback failed: %s", ex)  # pylint: disable=do-not-log-exceptions-if-not-debug
 
     def _is_transient_error(self, response: OneSettingsResponse) -> bool:
         """Check if the response indicates a transient error.

sdk/monitor/azure-monitor-opentelemetry-exporter/azure/monitor/opentelemetry/exporter/_configuration/_utils.py

@@ -6,7 +6,7 @@
 import logging
 
 # mypy: disable-error-code="import-untyped"
-import requests # pylint: disable=networking-import-outside-azure-core-transport
+import requests  # pylint: disable=networking-import-outside-azure-core-transport
 
 from azure.monitor.opentelemetry.exporter._constants import (
     _ONE_SETTINGS_DEFAULT_REFRESH_INTERVAL_SECONDS,
@@ -124,16 +124,24 @@ def make_onesettings_request(
 
         return _parse_onesettings_response(result)
     except requests.exceptions.Timeout as ex:
-        logger.warning("OneSettings request timed out: %s", str(ex)) # pylint: disable=do-not-log-exceptions-if-not-debug
+        logger.warning(
+            "OneSettings request timed out: %s", str(ex)
+        )  # pylint: disable=do-not-log-exceptions-if-not-debug
         return OneSettingsResponse(has_exception=True)
     except requests.exceptions.RequestException as ex:
-        logger.warning("Failed to fetch configuration from OneSettings: %s", str(ex)) # pylint: disable=do-not-log-exceptions-if-not-debug
+        logger.warning(
+            "Failed to fetch configuration from OneSettings: %s", str(ex)
+        )  # pylint: disable=do-not-log-exceptions-if-not-debug
         return OneSettingsResponse(has_exception=True)
     except json.JSONDecodeError as ex:
-        logger.warning("Failed to parse OneSettings response: %s", str(ex)) # pylint: disable=do-not-log-exceptions-if-not-debug
+        logger.warning(
+            "Failed to parse OneSettings response: %s", str(ex)
+        )  # pylint: disable=do-not-log-exceptions-if-not-debug
         return OneSettingsResponse(has_exception=True)
     except Exception as ex:  # pylint: disable=broad-exception-caught
-        logger.warning("Unexpected error while fetching configuration: %s", str(ex)) # pylint: disable=do-not-log-exceptions-if-not-debug
+        logger.warning(
+            "Unexpected error while fetching configuration: %s", str(ex)
+        )  # pylint: disable=do-not-log-exceptions-if-not-debug
         return OneSettingsResponse(has_exception=True)
 
 
@@ -197,9 +205,13 @@ def _parse_onesettings_response(response: requests.Response) -> OneSettingsRespo
                 if settings and settings.get(_ONE_SETTINGS_CHANGE_VERSION_KEY) is not None:
                     version = int(settings.get(_ONE_SETTINGS_CHANGE_VERSION_KEY))  # type: ignore
             except (UnicodeDecodeError, json.JSONDecodeError) as ex:
-                logger.warning("Failed to decode OneSettings response content: %s", str(ex)) # pylint: disable=do-not-log-exceptions-if-not-debug
+                logger.warning(
+                    "Failed to decode OneSettings response content: %s", str(ex)
+                )  # pylint: disable=do-not-log-exceptions-if-not-debug
             except ValueError as ex:
-                logger.warning("Failed to parse OneSettings change version: %s", str(ex)) # pylint: disable=do-not-log-exceptions-if-not-debug
+                logger.warning(
+                    "Failed to parse OneSettings change version: %s", str(ex)
+                )  # pylint: disable=do-not-log-exceptions-if-not-debug
     elif status_code == 400:
         logger.warning("Bad request to OneSettings: %s", response.content)
     elif status_code == 404:

sdk/monitor/azure-monitor-opentelemetry-exporter/azure/monitor/opentelemetry/exporter/_configuration/_worker.py

@@ -141,7 +141,9 @@ def _get_configuration(self) -> None:
                     # Capture interval while we have the lock
                     interval = self._refresh_interval
             except Exception as ex:  # pylint: disable=broad-exception-caught
-                logger.warning("Configuration refresh failed: %s", ex) # pylint: disable=do-not-log-exceptions-if-not-debug
+                logger.warning(
+                    "Configuration refresh failed: %s", ex
+                )  # pylint: disable=do-not-log-exceptions-if-not-debug
                 # Use current interval on error
                 interval = self.get_refresh_interval()
 

sdk/monitor/azure-monitor-opentelemetry-exporter/azure/monitor/opentelemetry/exporter/_performance_counters/_manager.py

@@ -79,7 +79,9 @@ def _get_process_cpu(options: CallbackOptions) -> Iterable[Observation]:
         cpu_percent = _PROCESS.cpu_percent(interval=None)
         yield Observation(cpu_percent, {})
     except (psutil.NoSuchProcess, psutil.AccessDenied, Exception) as e:  # pylint: disable=broad-except
-        _logger.exception("Error getting process CPU usage: %s", e)  # pylint: disable=logging-not-lazy, do-not-use-logging-exception
+        _logger.exception(
+            "Error getting process CPU usage: %s", e
+        )  # pylint: disable=logging-not-lazy, do-not-use-logging-exception
         yield Observation(0.0, {})
 
 
@@ -110,7 +112,9 @@ def _get_process_cpu_normalized(options: CallbackOptions) -> Iterable[Observatio
 
         yield Observation(normalized_cpu_percent, {})
     except (psutil.NoSuchProcess, psutil.AccessDenied, Exception) as e:  # pylint: disable=broad-except
-        _logger.exception("Error getting normalized process CPU usage: %s", e)  # pylint: disable=logging-not-lazy, do-not-use-logging-exception
+        _logger.exception(
+            "Error getting normalized process CPU usage: %s", e
+        )  # pylint: disable=logging-not-lazy, do-not-use-logging-exception
         yield Observation(0.0, {})
 
 
@@ -131,7 +135,9 @@ def _get_available_memory(options: CallbackOptions) -> Iterable[Observation]:
         available_memory = psutil.virtual_memory().available
         yield Observation(available_memory, {})
     except Exception as e:  # pylint: disable=broad-except
-        _logger.exception("Error getting available memory: %s", e)  # pylint: disable=logging-not-lazy, do-not-use-logging-exception
+        _logger.exception(
+            "Error getting available memory: %s", e
+        )  # pylint: disable=logging-not-lazy, do-not-use-logging-exception
         yield Observation(0, {})
 
 
@@ -152,7 +158,9 @@ def _get_process_memory(options: CallbackOptions) -> Iterable[Observation]:
         private_bytes = _PROCESS.memory_info().rss
         yield Observation(private_bytes, {})
     except (psutil.NoSuchProcess, psutil.AccessDenied, Exception) as e:  # pylint: disable=broad-except
-        _logger.exception("Error getting process memory: %s", e)  # pylint: disable=logging-not-lazy, do-not-use-logging-exception
+        _logger.exception(
+            "Error getting process memory: %s", e
+        )  # pylint: disable=logging-not-lazy, do-not-use-logging-exception
         yield Observation(0, {})
 
 
@@ -245,7 +253,7 @@ def _get_processor_time(options: CallbackOptions) -> Iterable[Observation]:
         _LAST_CPU_TIMES = cpu_times
         yield Observation(utilization_percentage, {})
     except Exception as e:  # pylint: disable=broad-except
-        _logger.exception("Error getting processor time: %s", e) # pylint: disable=do-not-use-logging-exception
+        _logger.exception("Error getting processor time: %s", e)  # pylint: disable=do-not-use-logging-exception
         yield Observation(0.0, {})
 
 
@@ -603,10 +611,14 @@ def __init__(self, meter_provider=None):
                     if metric_class == RequestExecutionTime:
                         self._request_duration_histogram = performance_counter.gauge
                 except Exception as e:  # pylint: disable=broad-except
-                    _logger.warning("Failed to initialize performance counter %s: %s", metric_class.NAME[0], e) # pylint: disable=do-not-log-exceptions-if-not-debug
+                    _logger.warning(
+                        "Failed to initialize performance counter %s: %s", metric_class.NAME[0], e
+                    )  # pylint: disable=do-not-log-exceptions-if-not-debug
 
         except Exception as e:  # pylint: disable=broad-except
-            _logger.warning("Failed to setup performance counters: %s", e) # pylint: disable=do-not-log-exceptions-if-not-debug
+            _logger.warning(
+                "Failed to setup performance counters: %s", e
+            )  # pylint: disable=do-not-log-exceptions-if-not-debug
 
     def _record_span(self, span: ReadableSpan) -> None:
         try:

sdk/monitor/azure-monitor-opentelemetry-exporter/azure/monitor/opentelemetry/exporter/_quickpulse/_manager.py

@@ -202,7 +202,9 @@ def _do_initialize(self) -> bool:
             return True
 
         except Exception as e:  # pylint: disable=broad-except
-            _logger.warning("Failed to initialize QuickpulseManager: %s", e) # pylint: disable=do-not-log-exceptions-if-not-debug
+            _logger.warning(
+                "Failed to initialize QuickpulseManager: %s", e
+            )  # pylint: disable=do-not-log-exceptions-if-not-debug
             # Ensure cleanup happens and state is consistent
             self._cleanup()
             return False

sdk/monitor/azure-monitor-opentelemetry-exporter/azure/monitor/opentelemetry/exporter/export/_base.py

@@ -200,7 +200,9 @@ def __init__(self, **kwargs: Any) -> None:
 
                 collect_statsbeat_metrics(self)
             except Exception as e:  # pylint: disable=broad-except
-                logger.warning("Failed to initialize statsbeat metrics: %s", e) # pylint: disable=do-not-log-exceptions-if-not-debug
+                logger.warning(
+                    "Failed to initialize statsbeat metrics: %s", e
+                )  # pylint: disable=do-not-log-exceptions-if-not-debug
 
         # customer sdkstats initialization
         if self._should_collect_customer_sdkstats():
@@ -439,12 +441,12 @@ def _transmit(self, envelopes: List[TelemetryItem]) -> ExportResult:
 
                 if self._should_collect_stats():
                     exc_type = request_error.exc_type
-                    if exc_type is None or exc_type is type(None): # pylint: disable=unidiomatic-typecheck
+                    if exc_type is None or exc_type is type(None):  # pylint: disable=unidiomatic-typecheck
                         exc_type = request_error.__class__.__name__  # type: ignore
                     _update_requests_map(_REQ_EXCEPTION_NAME[1], value=exc_type)
                 result = ExportResult.FAILED_RETRYABLE
             except Exception as ex:
-                logger.exception( # pylint: disable=do-not-use-logging-exception
+                logger.exception(  # pylint: disable=do-not-use-logging-exception
                     "Envelopes could not be exported and are not retryable: %s.", ex
                 )
 
@@ -612,11 +614,11 @@ def _get_authentication_credential(**kwargs: Any) -> Optional[ManagedIdentityCre
                 credential = ManagedIdentityCredential()
                 return credential
     except ValueError as exc:
-        logger.error( # pylint: disable=do-not-log-exceptions-if-not-debug
+        logger.error(  # pylint: disable=do-not-log-exceptions-if-not-debug
             "APPLICATIONINSIGHTS_AUTHENTICATION_STRING, %s, has invalid format: %s", auth_string, exc
         )
     except Exception as e:
-        logger.error( # pylint: disable=do-not-log-exceptions-if-not-debug
+        logger.error(  # pylint: disable=do-not-log-exceptions-if-not-debug
             "Failed to get authentication credential and enable AAD: %s", e
         )
     return None

sdk/monitor/azure-monitor-opentelemetry-exporter/azure/monitor/opentelemetry/exporter/statsbeat/_manager.py

@@ -251,7 +251,9 @@ def _do_initialize(self, config: StatsbeatConfig) -> bool:
 
         except Exception as e:  # pylint: disable=broad-except
             # Log the error for debugging
-            logger.warning("Failed to initialize statsbeat: %s", e) # pylint: disable=do-not-log-exceptions-if-not-debug
+            logger.warning(
+                "Failed to initialize statsbeat: %s", e
+            )  # pylint: disable=do-not-log-exceptions-if-not-debug
             # Clean up on failure
             self._cleanup()
             return False
@@ -297,12 +299,16 @@ def _reconfigure(self, new_config: StatsbeatConfig) -> bool:
                 # Force flush before shutdown to ensure data is sent
                 self._meter_provider.force_flush(timeout_millis=5000)
             except Exception as e:  # pylint: disable=broad-except
-                logger.warning("Failed to flush meter provider during reconfiguration: %s", e) # pylint:disable=do-not-log-exceptions-if-not-debug
+                logger.warning(
+                    "Failed to flush meter provider during reconfiguration: %s", e
+                )  # pylint:disable=do-not-log-exceptions-if-not-debug
 
             try:
                 self._meter_provider.shutdown(timeout_millis=5000)
             except Exception as e:  # pylint: disable=broad-except
-                logger.warning("Failed to shutdown meter provider during reconfiguration: %s", e) # pylint:disable=do-not-log-exceptions-if-not-debug
+                logger.warning(
+                    "Failed to shutdown meter provider during reconfiguration: %s", e
+                )  # pylint:disable=do-not-log-exceptions-if-not-debug
 
         # Reset state but keep initialized=True
         self._meter_provider = None

sdk/monitor/azure-monitor-opentelemetry-exporter/azure/monitor/opentelemetry/exporter/statsbeat/_utils.py

@@ -156,8 +156,12 @@ def _get_connection_string_for_region_from_config(target_region: str, settings:
             return None
         return default_connection_string
     except (ValueError, TypeError, KeyError) as ex:
-        logger.warning("Error parsing configuration for region '%s': %s", target_region, str(ex)) # pylint: disable=do-not-log-exceptions-if-not-debug
+        logger.warning(
+            "Error parsing configuration for region '%s': %s", target_region, str(ex)
+        )  # pylint: disable=do-not-log-exceptions-if-not-debug
         return None
     except Exception as ex:  # pylint: disable=broad-exception-caught
-        logger.warning("Unexpected error getting stats connection string for region '%s': %s", target_region, str(ex)) # pylint: disable=do-not-log-exceptions-if-not-debug
+        logger.warning(
+            "Unexpected error getting stats connection string for region '%s': %s", target_region, str(ex)
+        )  # pylint: disable=do-not-log-exceptions-if-not-debug
         return None

sdk/monitor/azure-monitor-opentelemetry-exporter/azure/monitor/opentelemetry/exporter/statsbeat/customer/_utils.py

@@ -4,7 +4,7 @@
 from typing import Optional, List, Tuple, Union, Any
 
 # mypy: disable-error-code="import-untyped"
-from requests import ReadTimeout, Timeout # pylint: disable=networking-import-outside-azure-core-transport
+from requests import ReadTimeout, Timeout  # pylint: disable=networking-import-outside-azure-core-transport
 from azure.core.exceptions import ServiceRequestTimeoutError
 from azure.monitor.opentelemetry.exporter._constants import (
     _REQUEST,

sdk/monitor/azure-monitor-opentelemetry-exporter/samples/logs/sample_exception.py

@@ -35,7 +35,7 @@
     val = 1 / 0
     print(val)
 except ZeroDivisionError:
-    logger.exception("Error: Division by zero") # pylint: disable=do-not-use-logging-exception
+    logger.exception("Error: Division by zero")  # pylint: disable=do-not-use-logging-exception
 
 try:
     val = 1 / 0