Sich wiederholende Aufgaben mit Django-Sellerie - Django / Sellerie

Ich habe Probleme bei der Wiederholung von Aufgaben, hier ist das, was eine test-Aufgabe aussieht

from celery.decorators import task

@task()
def add(x, y):
    if not x or not y:
        raise Exception("test error")
    return x+y

Ich finde keine Dokumentation, was-so-ever, wie zu wiederholen, dekoriert Aufgaben, alles, was ich fand, war dieser:

self.retry(x,y, exc=exception, countdown=30)

die scheint nicht zu funktionieren mit meinem Fall, da es nicht self variable übergeben wird der Methode.

Edit:

Ich versuche das nun folgende ohne Erfolg:

from celery.decorators import task

@task()
def add(x, y):
    if not x or not y:
        try:
            raise Exception("test error")
        except Exception, e:
            add.retry([x, y], exc=e, countdown=30)
    return x+y

Bekomme ich die folgende Fehlermeldung:

TypeError("kwargs argument, um Wiederholungen können nicht leer sein. Aufgabe akzeptieren muss, **kwargs, siehe http://bit.ly/cAx3Bg",)

Irgendwelche Ideen?

InformationsquelleAutor der Frage RadiantHex | 2011-02-01

  1. 16

    Aufgabe muss akzeptieren, dass keyword-Argumente, die Sie verwendet, um Informationen unter anderem über die Anzahl der Wiederholungen. Ich denke, der code sollte wie folgt Aussehen:

    from celery.decorators import task

@task()
def add(x, y, **kwargs):
    if not x or not y:
        try:
            raise Exception("test error")
        except Exception, e:
            add.retry(args=[x, y], exc=e, countdown=30, kwargs=kwargs)
    return x+y

    **kwargs Hinzugefügt werden müssen, um die Unterschrift des add - Funktion, und übergeben als kwargs=kwargs beim Aufruf wiederholen.

    Hinweis: dieser Stil veraltet mit der Veröffentlichung von Sellerie 2.2.

    InformationsquelleAutor der Antwort Reiner Gerecke

  2. 26

    Können Sie Ihre retry-Parameter in den decorator:

    @task(default_retry_delay=5 * 60, max_retries=12)
def foo(bar):
  try:
      ...
  except Exception, exc:
      raise foo.retry(exc=exc)

    InformationsquelleAutor der Antwort dalore

Schreibe einen Kommentar