Merge tag '0.0.9' into develop

s3rius · s3rius · commit 0ab5dc2230da · 2022-08-30T23:57:19.000+04:00
0.0.9
diff --git a/pyproject.toml b/pyproject.toml
@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "taskiq"
-version = "0.0.8"
+version = "0.0.9"
 description = "Distributed task queue with full async support"
 authors = ["Pavel Kirilin <win10@list.ru>"]
 maintainers = ["Pavel Kirilin <win10@list.ru>"]
diff --git a/taskiq/formatters/json_formatter.py b/taskiq/formatters/json_formatter.py
@@ -16,9 +16,7 @@ def dumps(self, message: TaskiqMessage) -> BrokerMessage:
             task_id=message.task_id,
             task_name=message.task_name,
             message=message.json(),
-            labels={
-                "content_type": "application/json",
-            },
+            labels=message.labels,
         )
 
     def loads(self, message: BrokerMessage) -> TaskiqMessage:
