From 7aed5b8ea13dc201449b6453cdbc5ec2f69beaac Mon Sep 17 00:00:00 2001 From: shay23b Date: Sun, 22 Oct 2023 16:51:49 +0300 Subject: [PATCH] fix deserialize graphql --- memphis/message.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/memphis/message.py b/memphis/message.py index 54441cb..751a9c7 100644 --- a/memphis/message.py +++ b/memphis/message.py @@ -64,7 +64,7 @@ async def get_data_deserialized(self): if schema_type == "json": return json.loads(bytearray(self.message.data)) if schema_type == "graphql": - message = self.message.data + message = bytearray(self.message.data) decoded_str = message.decode("utf-8") return decoded_str else: