run precommit

Author: maltesander

docs/modules/hdfs/pages/usage-guide/monitoring.adoc

@@ -12,7 +12,7 @@ Starting with Stackable Data Platform 25.7, the built-in Prometheus metrics are
 The JMX exporter metrics are now deprecated and will be removed in a future release.
 ====
 
-This endpoint, in the case of the Namenode service, is reachable via the the `metrics` service: 
+This endpoint, in the case of the Namenode service, is reachable via the the `metrics` service:
 [source,shell]
 ----
 http://<hdfs-stacklet>-namenode-<rolegroup-name>-metrics:9870/prom

tests/templates/kuttl/logging/test_log_aggregation.py

@@ -23,9 +23,9 @@ def check_sent_events():
         },
     )
 
-    assert (
-        response.status_code == 200
-    ), "Cannot access the API of the vector aggregator."
+    assert response.status_code == 200, (
+        "Cannot access the API of the vector aggregator."
+    )
 
     result = response.json()
 
@@ -35,13 +35,13 @@ def check_sent_events():
         componentId = transform["componentId"]
 
         if componentId == "filteredInvalidEvents":
-            assert (
-                sentEvents is None or sentEvents["sentEventsTotal"] == 0
-            ), "Invalid log events were sent."
+            assert sentEvents is None or sentEvents["sentEventsTotal"] == 0, (
+                "Invalid log events were sent."
+            )
         else:
-            assert (
-                sentEvents is not None and sentEvents["sentEventsTotal"] > 0
-            ), f'No events were sent in "{componentId}".'
+            assert sentEvents is not None and sentEvents["sentEventsTotal"] > 0, (
+                f'No events were sent in "{componentId}".'
+            )
 
 
 if __name__ == "__main__":

tests/templates/kuttl/profiling/run-profiler.py

@@ -8,8 +8,7 @@
 
 def start_profiling_and_get_refresh_header(service_url):
     prof_page = requests.get(
-        f"{service_url}/prof"
-        f"?event={EVENT_TYPE}&duration={PROFILING_DURATION_IN_SEC}"
+        f"{service_url}/prof?event={EVENT_TYPE}&duration={PROFILING_DURATION_IN_SEC}"
     )
 
     assert prof_page.ok, f"""Profiling could not be started.
@@ -56,7 +55,7 @@ def fetch_flamegraph(service_url, refresh_path):
 
 def test_profiling(role, port):
     service_url = (
-        f"http://test-hdfs-{role}-default-0.test-hdfs-{role}-default-headless" f":{port}"
+        f"http://test-hdfs-{role}-default-0.test-hdfs-{role}-default-headless:{port}"
     )
 
     print(f"Test profiling on {service_url}")

tests/templates/kuttl/smoke/test_native_metrics.py

@@ -10,10 +10,7 @@
 
 
 def check_metrics(
-    namespace: str,
-    role: str,
-    port: int,
-    expected_metrics: list[str]
+    namespace: str, role: str, port: int, expected_metrics: list[str]
 ) -> None:
     response = requests.get(
         f"http://hdfs-{role}-default-metrics.{namespace}.svc.cluster.local:{port}/prom",
@@ -23,7 +20,9 @@ def check_metrics(
 
     for metric in expected_metrics:
         regex = re.compile(metric, re.MULTILINE)
-        assert regex.search(response.text) is not None, f"Metric '{metric}' not found for {role}"
+        assert regex.search(response.text) is not None, (
+            f"Metric '{metric}' not found for {role}"
+        )
 
 
 def check_namenode_metrics(namespace: str) -> None: