Desarrollo de Python
  1. Desarrollo de Python
  3. Cómo reiniciar una tarea fallida en Airflow
Intereting Posts
Referencias locales y globales con UnboundLocalError Cómo copiar / pegar DataFrame de StackOverflow en Python ¿Cómo soluciono incorrectamente las tags HTML anidadas / no cerradas? Sklearn: ¿Hay alguna forma de depurar tuberías? comparando contenidos de 2 listas de listas acceder a la base de datos existente en sqlalchemy en el proyecto matraz + filtro sqlalchemy ¿Cómo agregar elementos individualmente en la tupla? Script Python que imprime su fuente. Configuración del código de salida en Python cuando se produce una excepción Crypto / X509 bibliotecas de análisis de análisis para Python Reemplazo de múltiples cadenas similares finalización de la pestaña ipython para la clase dict personalizada Cómo agregar ancla en elemento de lista Cuadernos Jupyter: “Permiso denegado” al intentar crear un nuevo cuaderno to_sql pyodbc recuento incorrecto o error de syntax

Cómo reiniciar una tarea fallida en Airflow

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:

  1. Vaya a dag y dag run de la ejecución que desea cambiar
  2. Haga clic en GraphView
  3. Haga clic en la tarea A
  4. Haga clic en “Borrar”

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.