enable_insecure_serializers

celery/app/base.py

@@ -20,6 +20,7 @@ from operator import attrgetter
 
 from billiard.util import register_after_fork
 from kombu.clocks import LamportClock
+from kombu.serialization import enable_insecure_serializers
 from kombu.utils import cached_property
 
 from celery import platforms
@@ -116,6 +117,8 @@ class Celery(object):
         if include:
             self._preconf['CELERY_IMPORTS'] = include
 
+        enable_insecure_serializers()
+
         # Apply fixups.
         self.fixups = set(fixups or ())
         for fixup in self.fixups | BUILTIN_FIXUPS: