Merge branch 'release/0.8.3'

Author: s3rius

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "taskiq"
-version = "0.8.2"
+version = "0.8.3"
 description = "Distributed task queue with full async support"
 authors = ["Pavel Kirilin <[email protected]>"]
 maintainers = ["Pavel Kirilin <[email protected]>"]

taskiq/__init__.py

@@ -1,4 +1,6 @@
 """Distributed task manager."""
+from importlib.metadata import version
+
 from taskiq_dependencies import Depends as TaskiqDepends
 
 from taskiq.abc.broker import AsyncBroker, AsyncTaskiqDecoratedTask
@@ -30,13 +32,6 @@
 from taskiq.state import TaskiqState
 from taskiq.task import AsyncTaskiqTask
 
-try:
-    # Python 3.8+
-    from importlib.metadata import version  # noqa: WPS433
-except ImportError:
-    # Python 3.7
-    from importlib_metadata import version  # noqa: WPS433
-
 __version__ = version("taskiq")
 __all__ = [
     "__version__",

taskiq/abc/broker.py

@@ -153,7 +153,7 @@ async def startup(self) -> None:
 
         for middleware in self.middlewares:
             if middleware.__class__.startup != TaskiqMiddleware.startup:
-                await maybe_awaitable(middleware.startup)
+                await maybe_awaitable(middleware.startup())
 
         await self.result_backend.startup()
 

taskiq/middlewares/prometheus_middleware.py

@@ -29,12 +29,6 @@ def __init__(
     ) -> None:
         super().__init__()
 
-        self.found_errors = None
-        self.received_tasks = None
-        self.success_tasks = None
-        self.saved_results = None
-        self.execution_time = None
-
         metrics_path = metrics_path or Path(gettempdir()) / "taskiq_worker"
 
         if not metrics_path.exists():
@@ -76,7 +70,7 @@ def __init__(
         )
         self.execution_time = Histogram(
             "execution_time",
-            "Tome of function execution",
+            "Time of function execution",
             ["task_name"],
         )
         self.server_port = server_port
@@ -110,8 +104,6 @@ def pre_execute(
         :param message: current message.
         :return: message
         """
-        if self.received_tasks is None:
-            return message
         self.received_tasks.labels(message.task_name).inc()
         return message
 
@@ -126,12 +118,6 @@ def post_execute(
         :param message: received message.
         :param result: result of the execution.
         """
-        if (  # noqa: WPS337
-            self.success_tasks is None
-            or self.execution_time is None
-            or self.found_errors is None
-        ):
-            return
         if result.is_err:
             self.found_errors.labels(message.task_name).inc()
         else:
@@ -149,6 +135,4 @@ def post_save(
         :param message: received message.
         :param result: result of execution.
         """
-        if self.saved_results is None:
-            return
         self.saved_results.labels(message.task_name).inc()