Desarrollo de Python
  1. Desarrollo de Python
  3. Cómo reiniciar una tarea fallida en Airflow
Intereting Posts
Cómo obtener funciones de audio BPM y tempo en Python backend matplotlib para visualización de plots remota (alternativa para gtk / x11) OS X El Capitan con homebrew Encontrar singulares / conjuntos de máximos / mínimos locales en una matriz 1D-NumPy (una vez más) ¿Por qué los valores de OrderedDict no son iguales? TypeError: se requiere un flotador Importación de la variable timeit.timeit en Python Frask-RESTful – Devuelve el formato de respuesta personalizado Python spyder conda instala fallas TensorFlow: Falló el lanzamiento de Blas GEMM Usando sublistas para crear nuevas listas donde los números no se repiten Python – Crear una lista con capacidad inicial Convertir una figura 2D en un cilindro en Python OpenCV, Python: elimina el posible estrechamiento al coser imágenes ¿Cómo funciona unicodedata.normalize (form, unistr)? Candelabro de matplotlib en minutos.

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.