fix: typing, middleware methods

Author: spikeninja

taskiq/middlewares/taskiq_admin_middleware.py

@@ -78,7 +78,7 @@ async def shutdown(self) -> None:
         if self._client is not None:
             await self._client.close()
 
-    async def _spawn_request(
+    def _spawn_request(
         self,
         endpoint: str,
         payload: dict[str, Any],
@@ -105,7 +105,7 @@ async def _send() -> None:
         self._pending.add(task)
         task.add_done_callback(self._pending.discard)
 
-    async def post_send(
+    def post_send(
         self,
         message: TaskiqMessage,
     ) -> Union[None, Coroutine[Any, Any, None], "CoroutineType[Any, Any, None]"]:
@@ -117,7 +117,7 @@ async def post_send(
 
         :param message: kicked message.
         """
-        await self._spawn_request(
+        self._spawn_request(
             f"/api/tasks/{message.task_id}/queued",
             {
                 "args": message.args,
@@ -129,7 +129,7 @@ async def post_send(
         )
         return super().post_send(message)
 
-    async def pre_execute(
+    def pre_execute(
         self,
         message: TaskiqMessage,
     ) -> Union[
@@ -146,7 +146,7 @@ async def pre_execute(
         :param message: incoming parsed taskiq message.
         :return: modified message.
         """
-        await self._spawn_request(
+        self._spawn_request(
             f"/api/tasks/{message.task_id}/started",
             {
                 "args": message.args,
@@ -158,7 +158,7 @@ async def pre_execute(
         )
         return super().pre_execute(message)
 
-    async def post_execute(
+    def post_execute(
         self,
         message: TaskiqMessage,
         result: TaskiqResult[Any],
@@ -172,7 +172,7 @@ async def post_execute(
         :param message: incoming message.
         :param result: result of execution for current task.
         """
-        await self._spawn_request(
+        self._spawn_request(
             f"/api/tasks/{message.task_id}/executed",
             {
                 "finishedAt": self._now_iso(),