فهرست منبع

Worker: task.reject_on_worker_lost must not send task-failed event.

Ask Solem 9 سال پیش
والد
کامیت
ddc7de1fd9
1فایلهای تغییر یافته به همراه1 افزوده شده و 0 حذف شده
  1. 1 0
      celery/worker/request.py

+ 1 - 0
celery/worker/request.py

@@ -365,6 +365,7 @@ class Request(object):
             )
             if reject:
                 self.reject(requeue=requeue)
+                send_failed_event = False
             else:
                 self.acknowledge()