Replaced string with bytes in BrokerMessage (#89)

s3rius · web-flow · commit 3ada714ac042 · 2023-04-07T19:14:06.000+04:00
diff --git a/taskiq/formatters/json_formatter.py b/taskiq/formatters/json_formatter.py
@@ -15,7 +15,7 @@ def dumps(self, message: TaskiqMessage) -> BrokerMessage:
         return BrokerMessage(
             task_id=message.task_id,
             task_name=message.task_name,
-            message=message.json(),
+            message=message.json().encode(),
             labels=message.labels,
         )
 
diff --git a/taskiq/message.py b/taskiq/message.py
@@ -24,5 +24,5 @@ class BrokerMessage(BaseModel):
 
     task_id: str
     task_name: str
-    message: str
+    message: bytes
     labels: Dict[str, str]

Original file line number	Diff line number	Diff line change
`@@ -15,7 +15,7 @@ def dumps(self, message: TaskiqMessage) -> BrokerMessage:`
`15`	`15`	`return BrokerMessage(`
`16`	`16`	`task_id=message.task_id,`
`17`	`17`	`task_name=message.task_name,`
`18`		`- message=message.json(),`
	`18`	`+ message=message.json().encode(),`
`19`	`19`	`labels=message.labels,`
`20`	`20`	`)`
`21`	`21`