Merge branch 'release/0.0.9'

Author: s3rius

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 <[email protected]>"]
 maintainers = ["Pavel Kirilin <[email protected]>"]

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: