重試與芹菜Http回調任務

Question

我在看芹菜的http回調任務 - http://celeryproject.org/docs/userguide/remote-tasks.html。當遠程終端可用時，它們工作得不錯 - 但是當它不可用時，我希望它重試（按照重試策略） - 或者即使遠程終端返回故障。目前看來這是一個錯誤，任務被忽略。

任何想法？

Answer 1

你應該能夠定義像你的任務：

class RemoteCall(Task): 
    default_retry_delay = 30 * 60 # retry in 30 minutes 

    def Run(self, arg, **kwargs): 
     try: 
      res = URL("http://example.com/").get_async(arg) 
     except (InvalidResponseError, RemoteExecuteError), exc: 
      self.retry([arg], exc=exc, *kwargs) 

這將繼續努力，它以MAX_RETRIES嘗試，每30分鐘一次。