Преглед на файлове

Erase by Merge 72b16ac, shadow name exception

PMickael преди 9 години
родител
ревизия
10d2637653
променени са 1 файла, в които са добавени 2 реда и са изтрити 1 реда
  1. 2 1
      celery/app/task.py

+ 2 - 1
celery/app/task.py

@@ -471,13 +471,14 @@ class Task(object):
         if self.__self__ is not None:
         if self.__self__ is not None:
             args = args if isinstance(args, tuple) else tuple(args or ())
             args = args if isinstance(args, tuple) else tuple(args or ())
             args = (self.__self__,) + args
             args = (self.__self__,) + args
+            shadow = shadow or self.shadow_name(args, kwargs, options)
 
 
         preopts = self._get_exec_options()
         preopts = self._get_exec_options()
         options = dict(preopts, **options) if options else preopts
         options = dict(preopts, **options) if options else preopts
         return app.send_task(
         return app.send_task(
             self.name, args, kwargs, task_id=task_id, producer=producer,
             self.name, args, kwargs, task_id=task_id, producer=producer,
             link=link, link_error=link_error, result_cls=self.AsyncResult,
             link=link, link_error=link_error, result_cls=self.AsyncResult,
-            shadow=shadow or self.shadow_name(args, kwargs, options),
+            shadow=shadow,
             **options
             **options
         )
         )