Wie man eine fehlgeschlagene Aufgabe in Airflow neu startet

9

Ich verwende einen LocalExecutor und mein dag hat 3 Aufgaben , wobei Aufgabe (C) von Aufgabe (A) abhängig ist. Aufgabe (B) und Aufgabe (A) können parallel wie folgt ausgeführt werden:

A - & gt; C

B

So war Aufgabe (A) fehlgeschlagen und Aufgabe (B) lief gut . Task (C) muss noch ausgeführt werden, da Task (A) fehlgeschlagen ist.

Meine Frage ist Wie führe ich Task (A) alleine aus, so dass Task (C) ausgeführt wird sobald Task (A) abgeschlossen ist und Airflow UI sie als Erfolg markiert.

    
Chetan J 07.04.2017, 06:08
quelle

1 Antwort

19

In der Benutzeroberfläche:

  1. Gehe zu dag und dag run von dem Lauf, den du ändern möchtest
  2. Klicken Sie auf GraphView
  3. Klicken Sie auf Aufgabe A
  4. Klicken Sie auf "Löschen"

Dies lässt Task A erneut laufen, und wenn es erfolgreich ist, sollte Task C ausgeführt werden. Das funktioniert, weil der Scheduler, wenn Sie den Status einer Aufgabe löschen, diesen so behandeln wird, als wäre sie noch nicht für diesen dag-Lauf ausgeführt worden.

    
jhnclvr 10.04.2017, 18:31
quelle

Tags und Links

Django: Verwenden von Annotate, Count und Distinct in einem Queryset Kubernetes Multi-Pod-Bereitstellung