warn user on dummy result backend level

Author: igor-gorohovsky

taskiq/result_backends/dummy.py

@@ -1,3 +1,4 @@
+from logging import getLogger
 from typing import Any, TypeVar
 
 from taskiq.abc.result_backend import AsyncResultBackend
@@ -6,6 +7,9 @@
 _ReturnType = TypeVar("_ReturnType")
 
 
+logger = getLogger("taskiq")
+
+
 class DummyResultBackend(AsyncResultBackend[_ReturnType]):  # pragma: no cover
     """Default result backend, that does nothing."""
 
@@ -18,6 +22,7 @@ async def set_result(self, task_id: str, result: Any) -> None:
         :param task_id: current task id.
         :param result: result of execution.
         """
+        logger.warning("No result backend configured. Results will not be stored.")
 
     async def is_result_ready(self, task_id: str) -> bool:
         """
@@ -41,6 +46,8 @@ async def get_result(self, task_id: str, with_logs: bool = False) -> Any:
         :param with_logs: wether to fetch logs.
         :returns: TaskiqResult.
         """
+        logger.warning("No result backend configured. Returning dummy result...")
+
         return TaskiqResult(
             is_err=False,
             log=None,

taskiq/task.py

@@ -1,5 +1,4 @@
 import asyncio
-from logging import getLogger
 from time import time
 from typing import TYPE_CHECKING, Any, Generic, Optional
 
@@ -10,7 +9,6 @@
     ResultIsReadyError,
     TaskiqResultTimeoutError,
 )
-from taskiq.result_backends.dummy import DummyResultBackend
 
 if TYPE_CHECKING:  # pragma: no cover
     from taskiq.abc.result_backend import AsyncResultBackend
@@ -20,9 +18,6 @@
 _ReturnType = TypeVar("_ReturnType")
 
 
-logger = getLogger("taskiq")
-
-
 class AsyncTaskiqTask(Generic[_ReturnType]):
     """AsyncTask for AsyncResultBackend."""
 
@@ -88,9 +83,6 @@ async def wait_result(
             become ready in provided period of time.
         :return: task's return value.
         """
-        if isinstance(self.result_backend, DummyResultBackend):
-            logger.warning("No result backend configured. Returning dummy result...")
-
         start_time = time()
         while not await self.is_ready():
             await asyncio.sleep(check_interval)