Sellery geplante Aufgaben mit Ablaufzeit für jede Aufgabeninstanz?

Question

Ich habe eine Django-App mit Sellerie 4.1.0 und Sellerie Beat mit Datenbank-Scheduler. Ich möchte periodische Aufgaben von der Admin-Site aus ausführen und die Ablaufzeit für jede dieser Aufgaben festlegen. expire Eigenschaft in PeriodicTask ist ein Zeitplaner beendet die Erstellung neuer Nachrichten für diese Aufgabe, aber ich möchte das Ablaufdatum Aufgaben, die geplant sind aber älter als einige Wert, z. eine Stunde. Wie macht man das?

Ich bin wirklich verwirrt mit Sellerie Dokumentation und Unterschiede zwischen verschiedenen Versionen davon.

Answer 1

I löste es durch einen geplanten Task ausgeführt wird, die Aufgabe, mit den gewünschten Ablaufzeit definiert, lautet:

@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

Klingt, als ob Sie eine benutzerdefinierte scheduler class verwenden müssen.