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

ack retry after event sent

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

+ 3 - 3
celery/worker/job.py

@@ -317,13 +317,13 @@ class Request(object):
 
 
     def on_retry(self, exc_info):
     def on_retry(self, exc_info):
         """Handler called if the task should be retried."""
         """Handler called if the task should be retried."""
+        if self.task.acks_late:
+            self.acknowledge()
+
         self.send_event('task-retried', uuid=self.id,
         self.send_event('task-retried', uuid=self.id,
                          exception=safe_repr(exc_info.exception.exc),
                          exception=safe_repr(exc_info.exception.exc),
                          traceback=safe_str(exc_info.traceback))
                          traceback=safe_str(exc_info.traceback))
 
 
-        if self.task.acks_late:
-            self.acknowledge()
-
         if _does_info:
         if _does_info:
             info(self.retry_msg.strip(), {
             info(self.retry_msg.strip(), {
                 'id': self.id, 'name': self.name,
                 'id': self.id, 'name': self.name,