on_decode_error now uses safe_str when dumping the message body

celery/worker/consumer.py

@@ -80,7 +80,7 @@ from celery.app import app_or_default
 from celery.datastructures import AttributeDict
 from celery.exceptions import NotRegistered
 from celery.utils import noop
-from celery.utils.encoding import safe_repr
+from celery.utils.encoding import safe_repr, safe_str
 from celery.utils.timer2 import to_timestamp
 from celery.worker import state
 from celery.worker.job import TaskRequest, InvalidTaskError
@@ -429,7 +429,8 @@ class Consumer(object):
         self.logger.critical("Can't decode message body: %r "
                              "(type:%r encoding:%r raw:%r')" % (
                                 exc, message.content_type,
-                                message.content_encoding, message.body))
+                                message.content_encoding,
+                                safe_str(message.body)))
         message.ack()
 
     def reset_pidbox_node(self):