decode body bytes

cenkalti · Mar 8, 2018 · c32b883 · c32b883
1 parent a5585ca
commit c32b883
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/kuyruk/worker.py b/kuyruk/worker.py
@@ -178,6 +178,8 @@ def _process_message(self, message: amqp.Message) -> None:
             return
 
         try:
+            if isinstance(message.body, bytes):
+                message.body = message.body.decode()
             description = json.loads(message.body)
         except Exception:
             logger.error("Cannot decode message. Dropping. Message: %r", message.body)