style: reformat with darker

ingomueller-net · Nov 28, 2024 · 6fb1ec7 · 6fb1ec7
1 parent 1d5b9a7
commit 6fb1ec7
Showing 1 changed file with 21 additions and 12 deletions.
diff --git a/substrait_consumer/tests/functional/relations/test_aggregate_relation.py b/substrait_consumer/tests/functional/relations/test_aggregate_relation.py
@@ -15,18 +15,27 @@
 @pytest.fixture
 def mark_consumer_tests_as_xfail(request):
     """Marks a subset of tests as expected to be fail."""
-    producer = request.getfixturevalue('producer')
-    consumer = request.getfixturevalue('consumer')
-    test_name = request.getfixturevalue('test_name')
-    if consumer.__class__.__name__ == 'DuckDBConsumer':
-        if producer.__class__.__name__ != 'DuckDBProducer':
-            pytest.skip(reason=f'Unsupported Integration: DuckDBConsumer with non {producer.__class__.__name__}')
-    elif consumer.__class__.__name__ == 'DataFusionConsumer':
-        if producer.__class__.__name__ != 'DataFusionProducer':
-            pytest.skip(reason=f'Unsupported Integration: DataFusionConsumer with non {producer.__class__.__name__}')
-    elif consumer.__class__.__name__ == 'AceroConsumer':
-        if producer.__class__.__name__ == 'IsthmusProducer' and test_name == 'compute_within_aggregate':
-            pytest.skip(reason="'isthmus-acero-compute_within_aggregate' currently crashes")
+    producer = request.getfixturevalue("producer")
+    consumer = request.getfixturevalue("consumer")
+    test_name = request.getfixturevalue("test_name")
+    if consumer.__class__.__name__ == "DuckDBConsumer":
+        if producer.__class__.__name__ != "DuckDBProducer":
+            pytest.skip(
+                reason=f"Unsupported Integration: DuckDBConsumer with non {producer.__class__.__name__}"
+            )
+    elif consumer.__class__.__name__ == "DataFusionConsumer":
+        if producer.__class__.__name__ != "DataFusionProducer":
+            pytest.skip(
+                reason=f"Unsupported Integration: DataFusionConsumer with non {producer.__class__.__name__}"
+            )
+    elif consumer.__class__.__name__ == "AceroConsumer":
+        if (
+            producer.__class__.__name__ == "IsthmusProducer"
+            and test_name == "compute_within_aggregate"
+        ):
+            pytest.skip(
+                reason="'isthmus-acero-compute_within_aggregate' currently crashes"
+            )
 
 
 @pytest.mark.usefixtures("prepare_small_tpch_parquet_data")