セロリで再試行するコールバックのタスク

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分ごとに1回にそれをしようとし続けます。