Dependencies update, fixed some lints.

Signed-off-by: Pavel Kirilin <win10@list.ru>

Author: s3rius

.flake8

@@ -91,15 +91,6 @@ ignore =
   ; Do not perform function calls in argument defaults.
   B008,
 
-  ; all init files
-  __init__.py:
-  ; ignore not used imports
-  F401,
-  ; ignore import with wildcard
-  F403,
-  ; Found wrong metadata variable
-  WPS410,
-
 per-file-ignores =
   ; all tests
   test_*.py,tests.py,tests_*.py,*/tests/*:
@@ -116,6 +107,15 @@ per-file-ignores =
   ; Found outer scope names shadowing
   tests/conftest.py: WPS442
 
+  ; all init files
+  __init__.py:
+  ; ignore not used imports
+  F401,
+  ; ignore import with wildcard
+  F403,
+  ; Found wrong metadata variable
+  WPS410,
+
 exclude =
   ./.git,
   ./venv,

README.md

@@ -15,7 +15,7 @@ async def test() -> None:
 
 ## Non-obvious things
 
-You can configure kafka producer and consumer with special methods `configure_producer` and `configure_consumer`.  
+You can configure kafka producer and consumer with special methods `configure_producer` and `configure_consumer`.
 Example:
 ```python
 from taskiq_aio_kafka import AioKafkaBroker

poetry.lock

@@ -24,20 +24,20 @@ keywords = ["taskiq", "tasks", "distributed", "async", "kafka", "aiokafka"]
 packages = [{ include = "taskiq_aio_kafka" }]
 
 [tool.poetry.dependencies]
-python = "^3.7"
+python = "^3.8.1"
 taskiq = "^0"
 aiokafka = "^0.8.0"
 pydantic = "^1.10.7"
 
 [tool.poetry.group.dev.dependencies]
 pytest = "^7.1.2"
-flake8 = "^4.0.1"
+flake8 = "^6"
 isort = "^5.10.1"
 mypy = "^1.2.0"
 pre-commit = "^2.20.0"
 yesqa = "^1.3.0"
 autoflake = "^1.4"
-wemake-python-styleguide = "^0.16.1"
+wemake-python-styleguide = "^0.18.0"
 coverage = "^6.4.2"
 pytest-cov = "^3.0.0"
 mock = "^4.0.3"

pyproject.toml

@@ -1,5 +1,4 @@
 import asyncio
-import pickle  # noqa: S403
 from logging import getLogger
 from typing import Any, AsyncGenerator, Callable, List, Optional, Set, TypeVar, Union
 

taskiq_aio_kafka/broker.py

@@ -40,15 +40,15 @@ class KafkaProducerParameters(BaseModel):
 class KafkaConsumerParameters(BaseModel):
     """Parameters to kafka consumer."""
 
-    client_id: str = "aiokafka-" + __version__  # noqa: WPS336
+    client_id: str = f"aiokafka-{__version__}"
     group_id: Optional[str] = None
     key_deserializer: Optional[Callable[..., Any]] = None
     value_deserializer: Optional[Callable[..., Any]] = None
     fetch_max_wait_ms: int = 500
     fetch_max_bytes: int = 52428800
     fetch_min_bytes: int = 1
-    max_partition_fetch_bytes: int = 1 * 1024 * 1024  # noqa: WPS345
-    request_timeout_ms: int = 40 * 1000  # noqa: WPS432
+    max_partition_fetch_bytes: int = 1024 * 1024
+    request_timeout_ms: int = 40000
     retry_backoff_ms: int = 100
     auto_offset_reset: str = "latest"
     enable_auto_commit: bool = True

taskiq_aio_kafka/models.py

@@ -1,5 +1,5 @@
 import asyncio
-import pickle  # noqa: S403
+import pickle
 from typing import Dict, List
 from uuid import uuid4
 
@@ -17,7 +17,7 @@ async def get_first_task(broker: AioKafkaBroker) -> bytes:  # type: ignore
 
     :returns: first message from listen method
     """
-    async for message in broker.listen():  # noqa: WPS328
+    async for message in broker.listen():
         return message
 
 
@@ -65,13 +65,13 @@ async def test_startup(
     :param broker_without_arguments: broker.
     :param base_topic_name: base topic name.
     """
-    assert broker_without_arguments._aiokafka_consumer  # noqa: WPS437
-    assert broker_without_arguments._aiokafka_producer  # noqa: WPS437
-    assert broker_without_arguments._kafka_admin_client  # noqa: WPS437
+    assert broker_without_arguments._aiokafka_consumer
+    assert broker_without_arguments._aiokafka_producer
+    assert broker_without_arguments._kafka_admin_client
 
     all_kafka_topics: List[
         str
-    ] = broker_without_arguments._kafka_admin_client.list_topics()  # noqa: WPS437
+    ] = broker_without_arguments._kafka_admin_client.list_topics()
 
     assert broker_without_arguments._kafka_topic.name in all_kafka_topics