2017-11-15 2 views
1

私はセロリ4.1.0でdjangoアプリを持ち、データベーススケジューラでセロリを打ちました。私が望むのは、管理サイトから定期的なタスクを実行し、各タスクの有効期限を設定することです。 PeriodicTaskのexpireプロパティは、タイムスケジューラがそのタスクの新しいメッセージの作成を停止しますが、スケジュールされているが古い値よりも古いタスクを失効させたいとします。一時間。これを行う方法?各タスクインスタンスの有効期限を設定したセラースケジュールタスク?

私はセロリのドキュメントとその異なるバージョン間の違いと本当に混同しています。

答えて

0

私は、所望の有効期限の時間で定義されたタスクを実行するスケジュールされたタスクを実行して、それを解決:

@shared_task(bind=True, queue='q1', max_retries=3) 
def parent_task(self, arg1): 
    child_task.apply_async(kwargs={'arg1': arg1}, expires=86400) 


@shared_task(bind=True, queue='q1', max_retries=3) 
def child_task(self, arg1): 
    pass 
関連する問題