ruff ruff

Author: sbernauer

tests/templates/kuttl/logging/test_log_aggregation.py

@@ -4,18 +4,16 @@
 
 
 def send_opa_decision_request():
-    response = requests.post(
-        'http://test-opa-server:8081/v1/data/test/world'
-    )
+    response = requests.post("http://test-opa-server:8081/v1/data/test/world")
+
+    assert response.status_code == 200, "Cannot access the API of the opa cluster."
 
-    assert response.status_code == 200, \
-        'Cannot access the API of the opa cluster.'
 
 def check_sent_events():
     response = requests.post(
-        'http://opa-vector-aggregator:8686/graphql',
+        "http://opa-vector-aggregator:8686/graphql",
         json={
-            'query': """
+            "query": """
                 {
                     transforms(first:100) {
                         nodes {
@@ -29,31 +27,32 @@ 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, \
-                   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__':
+if __name__ == "__main__":
     send_opa_decision_request()
     time.sleep(10)
     check_sent_events()
-    print('Test successful!')
+    print("Test successful!")