We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 48f5f35 commit 71230c2Copy full SHA for 71230c2
1 file changed
taskiq/formatters/json_formatter.py
@@ -16,9 +16,7 @@ def dumps(self, message: TaskiqMessage) -> BrokerMessage:
16
task_id=message.task_id,
17
task_name=message.task_name,
18
message=message.json(),
19
- labels={
20
- "content_type": "application/json",
21
- },
+ labels=message.labels,
22
)
23
24
def loads(self, message: BrokerMessage) -> TaskiqMessage:
0 commit comments