芹菜工人不重試任務（）

Question

我有一個任務：

@celery.task(name='request_task',default_retry_delay=2,acks_late=True) 
    def request_task(data): 
     try: 
      if some_condition: 
       request_task.retry() 
     except Exception as e: 
      request_task.retry() 

我用芹菜MongoDB的經紀人和MongoDB結果後端啓用。

當任務的retry（）方法被調用時，無論是從條件語句還是在捕獲異常之後，任務都不會被重試。

在工作者的終端

我得到消息是這樣的：

[2012-08-10 19：21：54909：INFO/MainProcess]任務REQUEST_TASK [badb3131-8964-41b5-90a7-245a8131e68d]重試：任務可以重試

什麼可能是錯的？

更新：最後，我沒有解決這個問題，並且必須在任務內使用while循環，所以我的任務永遠不會被重試。

Answer 1

您應該閱讀關於在芹菜文檔重試的部分。 http://celery.readthedocs.org/en/latest/userguide/tasks.html#retrying

它看起來像爲了重試，你必須提出一個重試異常。

raise request_task.retry() 

這似乎使重試由裝飾您的任務的函數處理。