Ask Solem 15 anni fa
parent
commit
14807e6941
1 ha cambiato i file con 1 aggiunte e 1 eliminazioni
  1. 1 1
      celery/task/sets.py

+ 1 - 1
celery/task/sets.py

@@ -71,7 +71,7 @@ class subtask(AttributeDict):
             task_name = task
 
         init(task=task_name, args=tuple(args or ()),
-                             kwargs=dict(kwargs, **extra) or {},
+                             kwargs=dict(kwargs or {}, **extra),
                              options=options or {})
 
     def delay(self, *argmerge, **kwmerge):