Remove unnecessary changes to reduce PR length

quixstreams/sinks/base/__init__.py

@@ -1,14 +1,12 @@
 from .batch import SinkBatch
 from .exceptions import SinkBackpressureError
-from .item import SinkItem
 from .manager import SinkManager
 from .sink import BaseSink, BatchingSink
 
 __all__ = (
-    "BaseSink",
-    "BatchingSink",
-    "SinkBackpressureError",
     "SinkBatch",
-    "SinkItem",
+    "SinkBackpressureError",
     "SinkManager",
+    "BatchingSink",
+    "BaseSink",
 )

quixstreams/sinks/base/sink.py

@@ -1,6 +1,6 @@
 import abc
 import logging
-from typing import Any
+from typing import Any, Dict, List, Tuple
 
 from quixstreams.models import HeaderValue
 from quixstreams.sinks.base.batch import SinkBatch
@@ -35,7 +35,7 @@ def add(
         value: Any,
         key: Any,
         timestamp: int,
-        headers: list[tuple[str, HeaderValue]],
+        headers: List[Tuple[str, HeaderValue]],
         topic: str,
         partition: int,
         offset: int,
@@ -71,7 +71,7 @@ class BatchingSink(BaseSink):
     batching sink.
     """
 
-    _batches: dict[tuple[str, int], SinkBatch]
+    _batches: Dict[Tuple[str, int], SinkBatch]
 
     def __init__(self):
         self._batches = {}
@@ -95,7 +95,7 @@ def add(
         value: Any,
         key: Any,
         timestamp: int,
-        headers: list[tuple[str, HeaderValue]],
+        headers: List[Tuple[str, HeaderValue]],
         topic: str,
         partition: int,
         offset: int,

quixstreams/sources/base/manager.py

@@ -2,6 +2,7 @@
 import signal
 import threading
 from pickle import PicklingError
+from typing import List
 
 from quixstreams.logging import LOGGER_NAME, configure_logging
 from quixstreams.models import Topic
@@ -27,7 +28,7 @@ def __init__(self, source):
         super().__init__()
         self.source: BaseSource = source
 
-        self._exceptions: list[Exception] = []
+        self._exceptions: List[Exception] = []
         self._started = False
         self._stopping = False
 
@@ -167,7 +168,7 @@ class SourceManager:
     """
 
     def __init__(self):
-        self.processes: list[SourceProcess] = []
+        self.processes: List[SourceProcess] = []
 
     def register(self, source: BaseSource):
         """
@@ -187,11 +188,11 @@ def register(self, source: BaseSource):
         return process
 
     @property
-    def sources(self) -> list[BaseSource]:
+    def sources(self) -> List[BaseSource]:
         return [process.source for process in self.processes]
 
     @property
-    def topics(self) -> list[Topic]:
+    def topics(self) -> List[Topic]:
         return [process.source.producer_topic for process in self.processes]
 
     def start_sources(self) -> None: