Turn on isort check in Ruff (#597)

Author: gwaramadze

docs/build/build.py

@@ -1,6 +1,6 @@
 import pathlib
 
-from pydoc_markdown import PydocMarkdown, SmartProcessor, CrossrefProcessor
+from pydoc_markdown import CrossrefProcessor, PydocMarkdown, SmartProcessor
 from pydoc_markdown.contrib.loaders.python import PythonLoader
 from pydoc_markdown.contrib.processors.filter import FilterProcessor
 from pydoc_markdown.contrib.renderers.markdown import MarkdownRenderer

docs/tutorials/anomaly-detection/application.py

@@ -2,7 +2,6 @@
 
 from quixstreams import Application
 
-
 app = Application(
     broker_address=os.environ.get("BROKER_ADDRESS", "localhost:9092"),
     consumer_group="temperature_alerter",

docs/tutorials/purchase-filtering/producer.py

@@ -3,7 +3,6 @@
 
 from quixstreams import Application
 
-
 _app = Application(broker_address=os.environ.get("BROKER_ADDRESS", "localhost:9092"))
 topic = _app.topic(name="customer_purchases")
 

docs/tutorials/word-count/producer.py

@@ -1,9 +1,8 @@
 import os
 import time
-
-from quixstreams import Application
 from random import choice
 
+from quixstreams import Application
 
 _app = Application(broker_address=os.environ.get("BROKER_ADDRESS", "localhost:9092"))
 topic = _app.topic(name="product_reviews")

examples/bank_example/json_version/producer.py

@@ -1,7 +1,7 @@
 import time
 import uuid
 from os import environ
-from random import randint, random, choice
+from random import choice, randint, random
 
 from dotenv import load_dotenv
 

examples/bank_example/quix_platform_version/consumer.py

@@ -10,7 +10,6 @@
 
 from quixstreams import Application, State
 
-
 # Reminder: the platform will have these values available by default so loading the
 # environment would be unnecessary there.
 load_dotenv("./bank_example/quix_platform_version/quix_vars.env")

examples/bank_example/quix_platform_version/producer.py

@@ -1,6 +1,6 @@
 import time
 import uuid
-from random import randint, random, choice
+from random import choice, randint, random
 from time import sleep
 
 from dotenv import load_dotenv

pyproject.toml

@@ -56,6 +56,7 @@ ignore-init-method-arguments = true
 fix = true
 lint.select = [
   "F",  # Pyflakes
+  "I",  # isort
   "S",  # flake8-bandit
   "SLF",  # flake8-self
 ]

quixstreams/app.py

@@ -6,43 +6,43 @@
 import time
 import warnings
 from pathlib import Path
-from typing import Optional, List, Callable, Union, Literal, Tuple, Type
+from typing import Callable, List, Literal, Optional, Tuple, Type, Union
 
 from confluent_kafka import TopicPartition
-from pydantic import Field, AliasGenerator
+from pydantic import AliasGenerator, Field
 from pydantic_settings import PydanticBaseSettingsSource, SettingsConfigDict
 from typing_extensions import Self
 
-from .context import set_message_context, copy_context
-from .dataframe import StreamingDataFrame, DataframeRegistry
+from .context import copy_context, set_message_context
+from .dataframe import DataframeRegistry, StreamingDataFrame
 from .error_callbacks import (
     ConsumerErrorCallback,
     ProcessingErrorCallback,
     ProducerErrorCallback,
     default_on_processing_error,
 )
-from .kafka import AutoOffsetReset, Producer, Consumer, ConnectionConfig
-from .logging import configure_logging, LogLevel
+from .kafka import AutoOffsetReset, ConnectionConfig, Consumer, Producer
+from .logging import LogLevel, configure_logging
 from .models import (
+    DeserializerType,
+    SerializerType,
+    TimestampExtractor,
     Topic,
-    TopicConfig,
     TopicAdmin,
+    TopicConfig,
     TopicManager,
-    SerializerType,
-    DeserializerType,
-    TimestampExtractor,
 )
 from .platforms.quix import (
     QuixKafkaConfigsBuilder,
+    QuixTopicManager,
     check_state_dir,
     check_state_management_enabled,
-    QuixTopicManager,
 )
-from .processing import ProcessingContext, PausingManager
+from .processing import PausingManager, ProcessingContext
 from .rowconsumer import RowConsumer
 from .rowproducer import RowProducer
 from .sinks import SinkManager
-from .sources import SourceManager, BaseSource, SourceException
+from .sources import BaseSource, SourceException, SourceManager
 from .state import StateStoreManager
 from .state.recovery import RecoveryManager
 from .state.rocksdb import RocksDBOptionsType

quixstreams/checkpointing/__init__.py

@@ -1,4 +1,4 @@
-from .checkpoint import Checkpoint, BaseCheckpoint
+from .checkpoint import BaseCheckpoint, Checkpoint
 from .exceptions import InvalidStoredOffset
 
 __all__ = ["BaseCheckpoint", "Checkpoint", "InvalidStoredOffset"]