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

app.register_task now binds task to app

Ask Solem преди 8 години
родител
ревизия
a893527e8b
променени са 1 файла, в които са добавени 2 реда и са изтрити 0 реда
  1. 2 0
      celery/app/base.py

+ 2 - 0
celery/app/base.py

@@ -491,6 +491,8 @@ class Celery(object):
             task.name = self.gen_task_name(
                 task_cls.__name__, task_cls.__module__)
         self.tasks[task.name] = task
+        task._app = self
+        task.bind(self)
         return task
 
     def gen_task_name(self, name, module):