各タスクインスタンスの有効期限を設定したセラースケジュールタスク？

Question

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

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

Answer 1

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

@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 

を

Answer 2

あなたはカスタムscheduler classを使用する必要があります。