Wie kann ich in Sellery + Python auf Task-Parameter von der task_revoked-Funktion zugreifen?

Question

Ich versuche, einige Sachen aufzuräumen, nachdem ich eine laufende Aufgabe innerhalb des Selleries töte. Ich schlage zur Zeit 2 Probleme:

1) Innerhalb der Aufgabe Funktion Körper entzogen, wie kann ich Zugriff auf die Parameter erhalten, die die Aufgabe Funktion aufgerufen wurde: so zum Beispiel, wenn die Aufgabe wie folgt definiert ist:

@app.task() 
def foo(bar, baz): 
    pass 

Wie bekomme ich Zugriff auf bar und baz innerhalb der task_revoked.connect Code?

2) Ich möchte eine Aufgabe nur dann beenden, wenn ihr Zustand alles andere als X ist. Das bedeutet, die Aufgabe einerseits zu prüfen und andererseits den Status zu setzen. Den Zustand zu überprüfen könnte ich wahrscheinlich tun, aber ich habe Schwierigkeiten, den Kontext innerhalb des Aufgabenfunktionskörpers zu verstehen.

Wenn ich foo wie folgt definieren:

@app.task(bound=True) 
def foo(self, bar, baz): 
    pass 

und nennen es aus sagen .... Flask wie foo(bar, baz), dann werde ich eine Fehlermeldung erhalten, dass der dritte Parameter erwartet wird, die der Dekorateur bedeutet tut Fügen Sie keinen Kontext automatisch über den Parameter self hinzu.

die App einfach als celery.Celery()

Vielen Dank im Voraus

von Request-Objekt

Answer 1

Sie können Aufgaben args bekommen definiert.

from celery.signals import task_revoked 

@task_revoked.connect 
def my_task_revoked_handler(sender=None, body=None, *args, **kwargs): 
    print(kwargs['request'].args) 

Dies gibt die Argumente für die Aufgabe aus.

Update:

Sie haben bind nicht bound zu verwenden.

@app.task(bind=True) 
def foo(self, bar, baz):