Browse Source

celery.signature did not pass app properly for custom Signatures.

Ask Solem 9 years ago
parent
commit
85edb51823
1 changed files with 2 additions and 1 deletions
  1. 2 1
      celery/canvas.py

+ 2 - 1
celery/canvas.py

@@ -999,10 +999,11 @@ class chord(Signature):
 
 
 def signature(varies, *args, **kwargs):
+    app = kwargs.get('app')
     if isinstance(varies, dict):
         if isinstance(varies, abstract.CallableSignature):
             return varies.clone()
-        return Signature.from_dict(varies)
+        return Signature.from_dict(varies, app=app)
     return Signature(varies, *args, **kwargs)
 subtask = signature   # XXX compat