python - español - airflow worker

Cómo reiniciar una tarea fallida en Airflow

Question

Estoy usando un LocalExecutor y mi dag tiene 3 tareas donde la tarea (C) depende de la tarea (A). La tarea (B) y la tarea (A) pueden ejecutarse en paralelo algo así como a continuación

A -> C

segundo

Entonces la tarea (A) falló y la tarea (B) funcionó bien . La tarea (C) aún no se ha ejecutado porque la tarea (A) ha fallado.

Mi pregunta es cómo puedo ejecutar la Tarea (A) sola, por lo que la Tarea (C) se ejecuta una vez que la Tarea (A) finaliza y la IU de Flujo de aire los marca como exitosos.

Answer 1

En la interfaz de usuario:

1. Ve al dag, y dag ejecuta la carrera que quieres cambiar
2. Haga clic en GraphView
3. Haga clic en la tarea A
4. Haga clic en "Borrar"

Esto permitirá que la tarea A se ejecute nuevamente, y si tiene éxito, la tarea C debería ejecutarse. Esto funciona porque cuando borra el estado de una tarea, el planificador la tratará como si no se hubiera ejecutado antes para esta ejecución de dag.