fix: compatibility with Taskiq 0.13.0 (#50)

Author: danfimov

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "taskiq-sqs"
-version = "0.0.11"
+version = "0.1.1"
 description = "SQS Broker for TaskIQ"
 readme = "README.md"
 license = "MIT"
@@ -29,9 +29,9 @@ classifiers = [
 keywords = ["taskiq", "broker", "aws", "sqs"]
 requires-python = ">=3.11"
 dependencies = [
-    "taskiq>=0.12.6",
-    "capo-s3>=0.15.0",
-    "capo-sqs>=0.6.0",
+    "taskiq>=0.13.0",
+    "capo-s3>=0.16.0",
+    "capo-sqs>=0.7.0",
 ]
 
 [project.urls]

src/taskiq_sqs/result_backend.py

@@ -4,7 +4,6 @@
 import capo_s3
 from taskiq import AsyncResultBackend
 from taskiq.abc.serializer import TaskiqSerializer
-from taskiq.compat import model_dump, model_validate
 from taskiq.result import TaskiqResult
 from taskiq.serializers import JSONSerializer
 
@@ -110,7 +109,7 @@ async def set_result(
         await self._s3_client.put_object(
             bucket=self._bucket["name"],
             key=self._build_key(task_id),
-            body=self._serializer.dumpb(model_dump(result)),
+            body=self._serializer.dumpb(result.model_dump(mode="json")),
         )
 
     async def get_result(
@@ -136,10 +135,7 @@ async def get_result(
         except capo_s3.errors.ServiceError as exc:
             raise exceptions.ResultBackendError(code=exc.code) from exc
 
-        taskiq_result = model_validate(
-            TaskiqResult[_ReturnType],
-            self._serializer.loadb(body),
-        )
+        taskiq_result = TaskiqResult[_ReturnType].model_validate(self._serializer.loadb(body))
 
         if not with_logs:
             taskiq_result.log = None