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 como a continuación
A -> C
segundo
Así que la tarea (A) ha fallado y la tarea (B) ha funcionado bien . La tarea (C) aún no se ha ejecutado porque la tarea (A) ha fallado.
Mi pregunta es cómo ejecuto la Tarea (A) solo para que la Tarea (C) se ejecute una vez que la Tarea (A) se complete y la IU de Airflow los marque como exitosos.
En la interfaz de usuario:
Esto permitirá que la tarea A vuelva a ejecutarse y, si tiene éxito, la tarea C debería ejecutarse. Esto funciona porque cuando borra el estado de una tarea, el progtwigdor lo tratará como si no se hubiera ejecutado antes para esta ejecución dag.