Parcourir la source

Adds Signature.__json__

Ask Solem il y a 11 ans
Parent
commit
65a5d2866e
1 fichiers modifiés avec 4 ajouts et 1 suppressions
  1. 4 1
      celery/canvas.py

+ 4 - 1
celery/canvas.py

@@ -286,7 +286,10 @@ class Signature(dict):
     def __reduce__(self):
         # for serialization, the task type is lazily loaded,
         # and not stored in the dict itself.
-        return subtask, (dict(self), )
+        return signature, (dict(self), )
+
+    def __json__(self):
+        return dict(self)
 
     def reprcall(self, *args, **kwargs):
         args, kwargs, _ = self._merge(args, kwargs, {})