Jelajahi Sumber

retry argument to apply_async requires the publisher/connection to be handled manually

Ask Solem 15 tahun lalu
induk
melakukan
a925ca7545
1 mengubah file dengan 2 tambahan dan 1 penghapusan
  1. 2 1
      celery/task/base.py

+ 2 - 1
celery/task/base.py

@@ -397,7 +397,8 @@ class BaseTask(object):
         :keyword retry: If enabled sending of the task message will be retried
         :keyword retry: If enabled sending of the task message will be retried
                         in the event of connection loss or failure.  Default
                         in the event of connection loss or failure.  Default
                         is taken from the :setting:`CELERY_TASK_PUBLISH_RETRY`
                         is taken from the :setting:`CELERY_TASK_PUBLISH_RETRY`
-                        setting.
+                        setting.  Note you need to handle the
+                        publisher/connection manually for this to work.
 
 
         :keyword retry_policy:  Override the retry policy used.  See the
         :keyword retry_policy:  Override the retry policy used.  See the
                                 :setting:`CELERY_TASK_PUBLISH_RETRY` setting.
                                 :setting:`CELERY_TASK_PUBLISH_RETRY` setting.