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

task_prerun/task_postrun signals was not sent by celeryd. Thanks to Regent Blaise.

Ask Solem преди 15 години
родител
ревизия
8fb931c015
променени са 1 файла, в които са добавени 1 реда и са изтрити 1 реда
  1. 1 1
      celery/worker/job.py

+ 1 - 1
celery/worker/job.py

@@ -97,7 +97,7 @@ class WorkerTaskTrace(TaskTrace):
         """Execute, trace and store the result of the task."""
         """Execute, trace and store the result of the task."""
         self.loader.on_task_init(self.task_id, self.task)
         self.loader.on_task_init(self.task_id, self.task)
         self.task.backend.process_cleanup()
         self.task.backend.process_cleanup()
-        return self._trace()
+        return super(WorkerTaskTrace, self).execute()
 
 
     def handle_success(self, retval, *args):
     def handle_success(self, retval, *args):
         """Handle successful execution."""
         """Handle successful execution."""