precommit

Author: maltesander

apps/ny_tlc_report.py

@@ -9,6 +9,7 @@
             need to be submitted along with the job.
 --output    Path to write the report as a CSV file.
 """
+
 import argparse
 
 from argparse import Namespace

rust/operator-binary/src/connect/server.rs

@@ -38,6 +38,7 @@ use stackable_operator::{
 use super::crd::CONNECT_APP_NAME;
 use crate::{
     connect::{
+        GRPC, HTTP,
         common::{self, SparkConnectRole, object_name},
         crd::{
             CONNECT_GRPC_PORT, CONNECT_UI_PORT, DEFAULT_SPARK_CONNECT_GROUP_NAME,

tests/templates/kuttl/logging/test_log_aggregation.py

@@ -4,9 +4,9 @@
 
 def check_sent_events():
     response = requests.post(
-        'http://spark-vector-aggregator:8686/graphql',
+        "http://spark-vector-aggregator:8686/graphql",
         json={
-            'query': """
+            "query": """
                 {
                     transforms(first:100) {
                         nodes {
@@ -20,29 +20,30 @@ 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()
 
-    transforms = result['data']['transforms']['nodes']
+    transforms = result["data"]["transforms"]["nodes"]
     for transform in transforms:
-        sentEvents = transform['metrics']['sentEventsTotal']
-        componentId = transform['componentId']
+        sentEvents = transform["metrics"]["sentEventsTotal"]
+        componentId = transform["componentId"]
 
-        if componentId == 'filteredInvalidEvents':
-            assert sentEvents is None or \
-                sentEvents['sentEventsTotal'] == 0, \
-                'Invalid log events were sent.'
+        if componentId == "filteredInvalidEvents":
+            assert sentEvents is None or sentEvents["sentEventsTotal"] == 0, (
+                "Invalid log events were sent."
+            )
         else:
-            assert sentEvents is not None and \
-                sentEvents['sentEventsTotal'] > 0, \
+            assert sentEvents is not None and sentEvents["sentEventsTotal"] > 0, (
                 f'No events were sent in "{componentId}".'
+            )
 
 
-if __name__ == '__main__':
+if __name__ == "__main__":
     check_sent_events()
-    print('Test successful!')
+    print("Test successful!")

tests/templates/kuttl/pyspark-ny-public-s3/ny_tlc_report.py

@@ -9,6 +9,7 @@
             need to be submitted along with the job.
 --output    Path to write the report as a CSV file.
 """
+
 import argparse
 
 from argparse import Namespace