fix linting in tests

nodestream-proj · Oct 31, 2023 · 8cc645d · 8cc645d
1 parent c0a7a9d
commit 8cc645d
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/tests/unit/pipeline/extractors/streams/test_kafka.py b/tests/unit/pipeline/extractors/streams/test_kafka.py
@@ -6,7 +6,9 @@
 
 @pytest.fixture
 def connector():
-    return KafkaStreamConnector("localhost:9092", "test-topic", max_records=1, poll_timeout_ms=10000)
+    return KafkaStreamConnector(
+        "localhost:9092", "test-topic", max_records=1, poll_timeout_ms=10000
+    )
 
 
 @pytest.mark.asyncio