Ich habe den folgenden CodeDjango Sellerie aktuelle Aufgabe mit ausgefallenen Daten wiederholt gesetzt nur
from utils import SendSMS
from celery.exceptions import *
@celery.task(bind=True, max_retries=3)
def send_sms(self,sms_list):
failed_items = []
for sms_item in sms_list:
status = SendSMS(**sms_item)
if status in ['Timeout','Error']:
failed_items.append(sms_item)
if len(failed_items) > 0:
raise self.retry(failed_items)
return "sms(s) send successfully."
ich die Aufgabe erneut zu versuchen will, aber mit unterschiedlichen Datensatz, mit nur Elemente fehlgeschlagen.
Ich meine, wie kann ich diese Zeile erreicht werden:
raise self.retry(failed_items) ?
Vielen Dank im Voraus.
Welche Fehler erhalten Sie, wenn Sie versuchen, über den Code auszuführen? –
Es heißt "Retry in 180s" –