Fixed when messages are acked. (#222)

Author: s3rius

taskiq/receiver/receiver.py

@@ -131,15 +131,15 @@ async def callback(  # noqa: C901, PLR0912
             taskiq_msg.task_id,
         )
 
-        # If broker has an ability to ack messages.
-        if isinstance(message, AckableMessage):
-            await maybe_awaitable(message.ack())
-
         result = await self.run_task(
             target=task.original_func,
             message=taskiq_msg,
         )
 
+        # If broker has an ability to ack messages.
+        if isinstance(message, AckableMessage):
+            await maybe_awaitable(message.ack())
+
         for middleware in self.broker.middlewares:
             if middleware.__class__.post_execute != TaskiqMiddleware.post_execute:
                 await maybe_awaitable(middleware.post_execute(taskiq_msg, result))