Changes after the best man in the world review

Author: chandr-andr

taskiq-redis/__init__.py renamed to __init__.py

@@ -3,6 +3,7 @@ name = "taskiq-redis"
 version = "0.1.0"
 description = ""
 authors = ["taskiq-team"]
+packages = [{ include = "taskiq", from = "taskiq_redis" }]
 
 [tool.poetry.dependencies]
 python = "^3.7"
@@ -25,6 +26,27 @@ anyio = "^3.6.1"
 pytest-env = "^0.6.2"
 fakeredis = "^1.8.1"
 
+[tool.mypy]
+strict = true
+ignore_missing_imports = true
+allow_subclassing_any = true
+allow_untyped_calls = true
+pretty = true
+show_error_codes = true
+implicit_reexport = true
+allow_untyped_decorators = true
+warn_return_any = false
+
+[[tool.mypy.overrides]]
+module = [
+    'redis.asyncio'
+]
+ignore_missing_imports = true
+
+[tool.isort]
+profile = "black"
+multi_line_output = 3
+
 [build-system]
 requires = ["poetry-core>=1.0.0"]
 build-backend = "poetry.core.masonry.api"

pyproject.toml

@@ -1,14 +1,15 @@
 import pickle
 from typing import Any, Dict, TypeVar
 
-from redis_client import RedisClient  # type: ignore
-from taskiq import AsyncResultBackend
+from redis_client import RedisClient
 from taskiq.abc.result_backend import TaskiqResult
 
+from taskiq import AsyncResultBackend
+
 _ReturnType = TypeVar("_ReturnType")
 
 
-class RedisAsyncResultBackend(AsyncResultBackend):
+class RedisAsyncResultBackend(AsyncResultBackend[_ReturnType]):
     """Async result based on redis."""
 
     def __init__(self, redis_url: str):

taskiq-redis/taskiq/result_backend/errors/__init__.py

@@ -1,6 +1,6 @@
 from typing import Mapping, Optional, Union
 
-from errors.redis_errors import RedisConnectionError  # type: ignore
+from errors import RedisConnectionError
 from redis.asyncio import Redis
 
 
@@ -13,9 +13,9 @@ def __init__(self, redis_url: str) -> None:
 
         :param redis_url: Redis URL to connect.
         """
-        self.redis_client: Redis = Redis.from_url(redis_url)
+        self.redis_client = Redis.from_url(redis_url)
 
-    async def close(self):
+    async def close(self) -> None:
         """Closes redis connection."""
         await self.redis_client.close()