Updated dependencies, fixed errors.

Signed-off-by: Pavel Kirilin <[email protected]>

Author: s3rius

README.md

@@ -72,8 +72,8 @@ RedisAsyncResultBackend parameters:
 * `keep_results` - flag to not remove results from Redis after reading.
 * `result_ex_time` - expire time in seconds (by default - not specified)
 * `result_px_time` - expire time in milliseconds (by default - not specified)
-> IMPORTANT: **It is highly recommended to use expire time ​​in RedisAsyncResultBackend**  
-> If you want to add expiration, either `result_ex_time` or `result_px_time` must be set.  
+> IMPORTANT: **It is highly recommended to use expire time ​​in RedisAsyncResultBackend**
+> If you want to add expiration, either `result_ex_time` or `result_px_time` must be set.
 >```python
 ># First variant
 >redis_async_result = RedisAsyncResultBackend(
@@ -86,4 +86,4 @@ RedisAsyncResultBackend parameters:
 >    redis_url="redis://localhost:6379",
 >    result_px_time=1000000,
 >)
->```
+>```

poetry.lock

@@ -18,17 +18,17 @@ repository = "https://github.com/taskiq-python/taskiq-redis"
 keywords = ["taskiq", "tasks", "distributed", "async", "redis", "result_backend"]
 
 [tool.poetry.dependencies]
-python = "^3.7"
+python = "^3.8.1"
 taskiq = "^0"
 redis = "^4.2.0"
 
 [tool.poetry.dev-dependencies]
 pytest = "^7.0"
-flake8 = "^4.0.1"
+flake8 = "^6"
 mypy = "^0.961"
 isort = "^5.10.1"
 yesqa = "^1.3.0"
-wemake-python-styleguide = "^0.16.1"
+wemake-python-styleguide = "^0.18"
 black = "^22.3.0"
 autoflake = "^1.4"
 pytest-cov = "^3.0.0"

pyproject.toml

@@ -4,6 +4,7 @@
 from redis.asyncio import ConnectionPool, Redis
 from taskiq import AsyncResultBackend
 from taskiq.abc.result_backend import TaskiqResult
+from taskiq.exceptions import ResultGetError
 
 from taskiq_redis.exceptions import (
     DuplicateExpireTimeSelectedError,
@@ -99,7 +100,7 @@ async def is_result_ready(self, task_id: str) -> bool:
         async with Redis(connection_pool=self.redis_pool) as redis:
             return bool(await redis.exists(task_id))
 
-    async def get_result(  # noqa: WPS210
+    async def get_result(
         self,
         task_id: str,
         with_logs: bool = False,
@@ -110,6 +111,8 @@ async def get_result(  # noqa: WPS210
         :param task_id: task's id.
         :param with_logs: if True it will download task's logs.
         :return: task's return value.
+
+        :raises ResultGetError: if result doesn't exist.
         """
         async with Redis(connection_pool=self.redis_pool) as redis:
             if self.keep_results:
@@ -121,6 +124,9 @@ async def get_result(  # noqa: WPS210
                     name=task_id,
                 )
 
+        if result_value is None:
+            raise ResultGetError("Result doesn't exist.")
+
         taskiq_result: TaskiqResult[_ReturnType] = pickle.loads(result_value)
 
         if not with_logs:

taskiq_redis/redis_backend.py

@@ -3,7 +3,7 @@
 from typing import TypeVar
 
 import pytest
-from taskiq import TaskiqResult
+from taskiq import ResultGetError, TaskiqResult
 
 from taskiq_redis import RedisAsyncResultBackend
 from taskiq_redis.exceptions import (
@@ -210,7 +210,7 @@ async def test_unsuccess_backend_expire_ex_param(
     )
     await asyncio.sleep(1.1)
 
-    with pytest.raises(TypeError):
+    with pytest.raises(ResultGetError):
         await backend.get_result(task_id=task_id)
 
 
@@ -270,5 +270,5 @@ async def test_unsuccess_backend_expire_px_param(
     )
     await asyncio.sleep(1.1)
 
-    with pytest.raises(TypeError):
+    with pytest.raises(ResultGetError):
         await backend.get_result(task_id=task_id)

tests/test_backend.py

@@ -1,13 +1,16 @@
 import asyncio
 import uuid
+from typing import Union
 
 import pytest
-from taskiq import AsyncBroker, BrokerMessage
+from taskiq import AckableMessage, AsyncBroker, BrokerMessage
 
 from taskiq_redis import ListQueueBroker, PubSubBroker
 
 
-async def get_message(broker: AsyncBroker) -> bytes:  # type: ignore
+async def get_message(  # type: ignore
+    broker: AsyncBroker,
+) -> Union[bytes, AckableMessage]:
     """
     Get a message from the broker.
 

tests/test_broker.py

@@ -2,6 +2,7 @@
 
 import pytest
 from taskiq import TaskiqResult
+from taskiq.exceptions import ResultGetError
 
 from taskiq_redis import RedisAsyncResultBackend
 
@@ -94,7 +95,7 @@ async def test_remove_results_after_reading(redis_url: str) -> None:
     )
 
     await result_backend.get_result(task_id=task_id)
-    with pytest.raises(Exception):
+    with pytest.raises(ResultGetError):
         await result_backend.get_result(task_id=task_id)