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

Merge branch 'dmarkey/master'

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

+ 3 - 0
celery/worker/job.py

@@ -321,6 +321,9 @@ class Request(object):
                          exception=safe_repr(exc_info.exception.exc),
                          traceback=safe_str(exc_info.traceback))
 
+        if self.task.acks_late:
+            self.acknowledge()
+
         if _does_info:
             info(self.retry_msg.strip(), {
                 'id': self.id, 'name': self.name,