Apply code formatting with black and fix flake8 issues

Co-authored-by: 4n4nd <22333506+4n4nd@users.noreply.github.com>

Author: Copilot

prometheus_api_client/prometheus_connect.py

@@ -1,4 +1,5 @@
 """A Class for collection of metrics from a Prometheus Host."""
+
 from urllib.parse import urlparse
 import bz2
 import os
@@ -41,7 +42,7 @@ class PrometheusConnect:
         Example: {"http_proxy": "<ip_address/hostname:port>", "https_proxy": "<ip_address/hostname:port>"}
     :param session (Optional) Custom requests.Session to enable complex HTTP configuration
     :param timeout: (Optional) A timeout (in seconds) applied to all requests
-    :param method: (Optional) (str) HTTP Method (GET or POST) to use for Query APIs that allow POST 
+    :param method: (Optional) (str) HTTP Method (GET or POST) to use for Query APIs that allow POST
         (/query, /query_range and /labels). Use POST for large and complex queries. Default is GET.
     """
 
@@ -55,7 +56,7 @@ def __init__(
         proxy: dict = None,
         session: Session = None,
         timeout: int = None,
-        method: str = "GET"
+        method: str = "GET",
     ):
         """Functions as a Constructor for the class PrometheusConnect."""
         if url is None:
@@ -69,7 +70,7 @@ def __init__(
 
         if not isinstance(method, str):
             raise TypeError("Method must be a string")
-        
+
         method = method.upper()
         if method not in {"GET", "POST"}:
             raise ValueError("Method can only be GET or POST")
@@ -130,7 +131,6 @@ def all_metrics(self, params: dict = None):
         self._all_metrics = self.get_label_values(label_name="__name__", params=params)
         return self._all_metrics
 
-
     def get_series(self, start: datetime, end: datetime, params: dict = None):
         """
         Get a list series happening between start and end times.
@@ -165,7 +165,6 @@ def get_series(self, start: datetime, end: datetime, params: dict = None):
             )
         return labels
 
-
     def get_label_names(self, params: dict = None):
         """
         Get a list of all labels.
@@ -480,7 +479,13 @@ def custom_query(self, query: str, params: dict = None, timeout: int = None):
         return data
 
     def custom_query_range(
-        self, query: str, start_time: datetime, end_time: datetime, step: str, params: dict = None, timeout: int = None
+        self,
+        query: str,
+        start_time: datetime,
+        end_time: datetime,
+        step: str,
+        params: dict = None,
+        timeout: int = None,
     ):
         """
         Send a query_range to a Prometheus Host.
@@ -617,21 +622,20 @@ def get_metric_aggregation(
                 raise TypeError("Invalid operation: " + operation)
         return aggregated_values
 
-
     def get_scrape_pools(self) -> list[str]:
         """
         Get a list of all scrape pools in activeTargets.
         """
         scrape_pools = []
-        for target in self.get_targets()['activeTargets']:
-            scrape_pools.append(target['scrapePool'])
+        for target in self.get_targets()["activeTargets"]:
+            scrape_pools.append(target["scrapePool"])
         return list(set(scrape_pools))
 
     def get_targets(self, state: str = None, scrape_pool: str = None):
         """
         Get a list of all targets from Prometheus.
 
-        :param state: (str) Optional filter for target state ('active', 'dropped', 'any'). 
+        :param state: (str) Optional filter for target state ('active', 'dropped', 'any').
                      If None, returns both active and dropped targets.
         :param scrape_pool: (str) Optional filter by scrape pool name
         :returns: (dict) A dictionary containing active and dropped targets
@@ -641,9 +645,9 @@ def get_targets(self, state: str = None, scrape_pool: str = None):
         """
         params = {}
         if state:
-            params['state'] = state
+            params["state"] = state
         if scrape_pool:
-            params['scrapePool'] = scrape_pool
+            params["scrapePool"] = scrape_pool
 
         response = self._session.request(
             method="GET",
@@ -660,8 +664,7 @@ def get_targets(self, state: str = None, scrape_pool: str = None):
             return response.json()["data"]
         else:
             raise PrometheusApiClientException(
-                "HTTP Status Code {} ({!r})".format(
-                    response.status_code, response.content)
+                "HTTP Status Code {} ({!r})".format(response.status_code, response.content)
             )
 
     def get_target_metadata(self, target: dict[str, str], metric: str = None):
@@ -679,12 +682,11 @@ def get_target_metadata(self, target: dict[str, str], metric: str = None):
 
         # Convert target dict to label selector string
         if metric:
-            params['metric'] = metric
+            params["metric"] = metric
 
         if target:
-            match_target = "{" + \
-                ",".join(f'{k}="{v}"' for k, v in target.items()) + "}"
-            params['match_target'] = match_target
+            match_target = "{" + ",".join(f'{k}="{v}"' for k, v in target.items()) + "}"
+            params["match_target"] = match_target
 
         response = self._session.request(
             method="GET",
@@ -701,8 +703,7 @@ def get_target_metadata(self, target: dict[str, str], metric: str = None):
             return response.json()["data"]
         else:
             raise PrometheusApiClientException(
-                "HTTP Status Code {} ({!r})".format(
-                    response.status_code, response.content)
+                "HTTP Status Code {} ({!r})".format(response.status_code, response.content)
             )
 
     def get_metric_metadata(self, metric: str, limit: int = None, limit_per_metric: int = None):
@@ -721,13 +722,13 @@ def get_metric_metadata(self, metric: str, limit: int = None, limit_per_metric:
         params = {}
 
         if metric:
-            params['metric'] = metric
+            params["metric"] = metric
 
         if limit:
-            params['limit'] = limit
+            params["limit"] = limit
 
         if limit_per_metric:
-            params['limit_per_metric'] = limit_per_metric
+            params["limit_per_metric"] = limit_per_metric
 
         response = self._session.request(
             method="GET",
@@ -745,15 +746,16 @@ def get_metric_metadata(self, metric: str, limit: int = None, limit_per_metric:
             formatted_data = []
             for k, v in data.items():
                 for v_ in v:
-                    formatted_data.append({
-                        "metric_name": k,
-                        "type": v_.get('type', 'unknown'),
-                        "help": v_.get('help', ''),
-                        "unit": v_.get('unit', '')
-                    })
+                    formatted_data.append(
+                        {
+                            "metric_name": k,
+                            "type": v_.get("type", "unknown"),
+                            "help": v_.get("help", ""),
+                            "unit": v_.get("unit", ""),
+                        }
+                    )
             return formatted_data
         else:
             raise PrometheusApiClientException(
-                "HTTP Status Code {} ({!r})".format(
-                    response.status_code, response.content)
+                "HTTP Status Code {} ({!r})".format(response.status_code, response.content)
             )