linter

Author: fangnx

src/confluent_kafka/admin/__init__.py

@@ -185,7 +185,7 @@ def _make_list_consumer_groups_result(f: concurrent.futures.Future, futmap: Any)
 
     @staticmethod
     def _make_consumer_groups_result(f: concurrent.futures.Future,
-                                      futmap: Dict[str, concurrent.futures.Future]) -> None:
+                                     futmap: Dict[str, concurrent.futures.Future]) -> None:
         """
         Map per-group results to per-group futures in futmap.
         """
@@ -211,7 +211,7 @@ def _make_consumer_groups_result(f: concurrent.futures.Future,
 
     @staticmethod
     def _make_consumer_group_offsets_result(f: concurrent.futures.Future,
-                                             futmap: Dict[str, concurrent.futures.Future]) -> None:
+                                            futmap: Dict[str, concurrent.futures.Future]) -> None:
         """
         Map per-group results to per-group futures in futmap.
         The result value of each (successful) future is ConsumerGroupTopicPartitions.
@@ -264,7 +264,7 @@ def _make_acls_result(f: concurrent.futures.Future, futmap: Dict[Any, concurrent
 
     @staticmethod
     def _make_futmap_result_from_list(f: concurrent.futures.Future,
-                                       futmap: Dict[Any, concurrent.futures.Future]) -> None:
+                                      futmap: Dict[Any, concurrent.futures.Future]) -> None:
         try:
 
             results = f.result()
@@ -317,7 +317,7 @@ def _create_future() -> concurrent.futures.Future:
     @staticmethod
     def _make_futures(futmap_keys: List[Any], class_check: Optional[type],
                       make_result_fn: Any) -> Tuple[concurrent.futures.Future,
-                                                     Dict[Any, concurrent.futures.Future]]:
+                                                    Dict[Any, concurrent.futures.Future]]:
         """
         Create futures and a futuremap for the keys in futmap_keys,
         and create a request-level future to be bassed to the C API.
@@ -341,7 +341,7 @@ def _make_futures(futmap_keys: List[Any], class_check: Optional[type],
     @staticmethod
     def _make_futures_v2(futmap_keys: Union[List[Any], Set[Any]], class_check: Optional[type],
                          make_result_fn: Any) -> Tuple[concurrent.futures.Future,
-                                                        Dict[Any, concurrent.futures.Future]]:
+                                                       Dict[Any, concurrent.futures.Future]]:
         """
         Create futures and a futuremap for the keys in futmap_keys,
         and create a request-level future to be bassed to the C API.
@@ -524,7 +524,7 @@ def _check_alter_user_scram_credentials_request(alterations: List[UserScramCrede
 
     @staticmethod
     def _check_list_offsets_request(topic_partition_offsets: Dict[_TopicPartition, OffsetSpec],
-                                     kwargs: Dict[str, Any]) -> None:
+                                    kwargs: Dict[str, Any]) -> None:
         if not isinstance(topic_partition_offsets, dict):
             raise TypeError("Expected topic_partition_offsets to be " +
                             "dict of [TopicPartitions,OffsetSpec] for list offsets request")

src/confluent_kafka/deserializing_consumer.py

@@ -24,7 +24,6 @@
                     ValueDeserializationError)
 from .serialization import (SerializationContext,
                             MessageField)
-from ._types import Deserializer
 
 
 class DeserializingConsumer(_ConsumerImpl):

src/confluent_kafka/serializing_producer.py

@@ -23,7 +23,7 @@
                             SerializationContext)
 from .error import (KeySerializationError,
                     ValueSerializationError)
-from ._types import HeadersType, DeliveryCallback, Serializer
+from ._types import HeadersType, DeliveryCallback
 
 
 class SerializingProducer(_ProducerImpl):