chore: ruff config added. Make use of ruff formatter

README.md

@@ -96,7 +96,7 @@ Run test:
 ./scripts/test
 ```
 
-Run code formatting (`black` and `isort`)
+Run code formatting with ruff:
 
 ```bash
 ./scripts/format

examples/confluent-example/confluent_example/streaming/engine.py

@@ -1,6 +1,6 @@
-from confluent_example import serializers
 from schema_registry.client import AsyncSchemaRegistryClient
 
+from confluent_example import serializers
 from kstreams import create_engine
 
 client = AsyncSchemaRegistryClient("http://localhost:8081")

examples/dataclasses-avroschema-example/dataclasses_avroschema_example/models.py

@@ -7,6 +7,7 @@
 @dataclass
 class User(AvroModel):
     "An User"
+
     name: str
     age: int
     pets: typing.List[str]
@@ -25,6 +26,7 @@ class Meta:
 @dataclass
 class Address(AvroModel):
     "An Address"
+
     street: str
     street_number: int
 

kstreams/clients.py

@@ -16,6 +16,7 @@ def __init__(
         self.config = kwargs
 
         if key_deserializer is None:
+
             def key_deserializer(key):
                 if key is not None:
                     return key.decode()
@@ -33,6 +34,7 @@ def __init__(
         self.config = kwargs
 
         if key_serializer is None:
+
             def key_serializer(key):
                 if key is not None:
                     return key.encode("utf-8")

kstreams/create.py

@@ -16,7 +16,6 @@ def create_engine(
     deserializer: Optional[Deserializer] = None,
     monitor: Optional[PrometheusMonitor] = None,
 ) -> StreamEngine:
-
     if monitor is None:
         monitor = PrometheusMonitor()
 

kstreams/engine.py

@@ -12,7 +12,8 @@
 from .prometheus.monitor import PrometheusMonitor
 from .rebalance_listener import MetricsRebalanceListener, RebalanceListener
 from .serializers import Deserializer, Serializer
-from .streams import Stream, StreamFunc, stream as stream_func
+from .streams import Stream, StreamFunc
+from .streams import stream as stream_func
 from .types import Headers
 from .utils import encode_headers
 

pyproject.toml

@@ -65,10 +65,6 @@ exclude = '''
 )/
 '''
 
-[tool.isort]
-profile = "black"
-known_first_party = ["kstreams", "tests", "examples"]
-
 [tool.commitizen]
 version = "0.15.1"
 tag_format = "$version"
@@ -89,3 +85,40 @@ ignore_missing_imports = true
 [[tool.mypy.overrides]]
 module = "prometheus_client.*"
 ignore_missing_imports = true
+
+[tool.ruff]
+line-length = 88
+exclude = [
+    ".bzr",
+    ".direnv",
+    ".eggs",
+    ".git",
+    ".hg",
+    ".mypy_cache",
+    ".nox",
+    ".pants.d",
+    ".ruff_cache",
+    ".svn",
+    ".tox",
+    ".venv",
+    "__pypackages__",
+    "_build",
+    "buck-out",
+    "build",
+    "dist",
+    "node_modules",
+    ".venv",
+]
+
+[tool.ruff.lint]
+select = [
+    # pycodestyle"
+    "E4",
+    "E7",
+    "E9",
+    "E501",
+    # Pyflakes
+    "F",
+    # isort
+    "I001"
+]

scripts/format

@@ -7,4 +7,5 @@ fi
 
 set -x
 
+${PREFIX}ruff format .
 ${PREFIX}ruff kstreams tests --fix

tests/test_backend_kafka.py

@@ -18,7 +18,6 @@ def test_plaintext_ok():
 
 
 def test_ssl_ok(ssl_context):
-
     kafka_backend = Kafka(
         security_protocol=SecurityProtocol.SSL, ssl_context=ssl_context
     )

tests/test_monitor.py

@@ -24,7 +24,6 @@ async def my_coroutine(_):
     consumer = stream.consumer
 
     for topic_partition in consumer.assignment():
-
         # super ugly notation but for now is the only way to get the metrics
         met_committed = (
             stream_engine.monitor.MET_COMMITTED.labels(