Contenido del curso
Conceptos básicos
Instalación y configuración
Implementando un DAG
Orquestar y monitorizar procesos
Sensores
Templates con Jinja
XComs
BranchPythonOperator
Proyecto
Cierre del curso
Task Actions
Contenido del curso
Task Actions
Los estados posibles para una instancia de tarea son:
none: la tarea aún no se ha puesto en cola para su ejecución (todavía no se cumplen sus dependencias)
scheduled: el programador ha determinado que se cumplen las dependencias de la tarea y debería ejecutarse
queued: La tarea ha sido asignada a un Ejecutor y está esperando un trabajador
running: La tarea se ejecuta en un trabajador (o en un ejecutor local/síncrono)
success: La tarea terminó de ejecutarse sin errores
shutdown: Se solicitó externamente que la tarea se cerrara cuando se estaba ejecutando
restarting: Se solicitó externamente que la tarea se reiniciara cuando se estaba ejecutando
failed: La tarea tuvo un error durante la ejecución y no pudo ejecutarse
skipped: La tarea se omitió debido a bifurcación, LatestOnly o similar.
upstream_failed: una tarea ascendente falló y la regla de activación dice que la necesitábamos
up_for_retry: La tarea falló, pero quedan reintentos y se reprogramará.
up_for_reschedule: La tarea es un Sensor que está en reschedulemodo
deferred: La tarea se ha aplazado a un activador
removed: La tarea ha desaparecido del DAG desde que comenzó la ejecució
Un caso común para el estatus 'queued', cuando deberia estar ejecutando, es cuando hay errores de sintaxis en el código del dag, hay que revisar, corregirlos y cuando lea de nuevo, el dag arranca automaticamente.
Si, es un problema común. Según la versión, airflow puede indicarnos el error de sintaxis en el home con un warning.
Task actions:
Seria importante que tambien se pueden hacer skip de tareas pero eso seguramente lo veremos en la clase del branch operator
Creo que la version de airflow influye porque actualmente no veo la seccion de Task Actions por ningun lado, estoy usando la version 2.10.2 ahora solo se ve el Clear task
Ya somos dos que no vemos las Task Actions en versiones actuales de Airflow.
En las nuevas versiones se habilitan después de darle clear las opciones de esta clase
A pesar de que el curso el "antiguo" el conocimiento sigue vigente
¿Cómo ayudan las Task Actions?
Las Task Actions son fundamentales para gestionar y corregir el flujo de un DAG cuando ocurren errores o situaciones inesperadas. Permiten intervenir manualmente en las tareas, como reintentar una ejecución fallida o marcar una tarea como exitosa, lo que es vital para mantener la continuidad de los procesos. Esto asegura que tus flujos de trabajo puedan recuperarse eficientemente sin necesidad de reiniciar todo el DAG.
Por qué hay tres filas con las opciones de PAST, FUTURE, UPSTREAM y DOWNSTREAM?
Como lo comenta el profe desde el minuto 6:00 no ayuda a hacer la action de la tarea para:
Eso sacado directo de la documentacion oficial
Buenas tardes colegas, estoy usando la versiòn 2.5.1 de AF , pero no veo por nigun lado las task actions, me pueden ayudar?!![
Buenas tardes, tienes que hacer click en uno de los cuadritos de ejecución, y del lado derecho te van a aparecer las task actions
En Apache Airflow, puedes realizar diversas acciones relacionadas con tareas. Aquí tienes algunas acciones comunes en español:
Si necesitas realizar alguna acción específica, no dudes en pedir ayuda.