소스 검색

signature(s, app=app) did not work properly when passing kwargs, as dicts were not properly upgraded to their subtask_type (e.g. Sig -> group)

Ask Solem 11 년 전
부모
커밋
845557372a
1개의 변경된 파일1개의 추가작업 그리고 1개의 파일을 삭제
  1. 1 1
      celery/canvas.py

+ 1 - 1
celery/canvas.py

@@ -639,7 +639,7 @@ class chord(Signature):
 
 
 def signature(varies, *args, **kwargs):
-    if not (args or kwargs) and isinstance(varies, dict):
+    if isinstance(varies, dict):
         if isinstance(varies, Signature):
             return varies.clone()
         return Signature.from_dict(varies)