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.
Introducción a Apache Airflow
Introducción al curso
¿Para qué sirve airflow?
¿Por qué usar airflow?
Resumen módulo 1
Conceptos básicos
DAG
Tasks y Operators
Scheduler
Instalación y configuración
Instalación de Apache Airflow usando Docker
Posibles configuraciones
Variables y conexiones
Implementando un DAG
Implementando un DAG
Bash Operator
Python Operator
Definiendo dependencias entre tareas
Custom Operator
Orquestar y monitorizar procesos
Orquestando un DAG I
Orquestando un DAG II
Monitoring
Task Actions
Trigger Rules
Sensores
¿Qué son los sensores?
ExternalTaskSensor
FileSensor
Templates con Jinja
¿Qué son los templates con Jinja?
XComs
¿Qué son los Xcoms?
BranchPythonOperator
BranchPythonOperator
Proyecto
Definición del proyecto
Cierre del curso
Cierre del curso
Comparte tu proyecto de Platzi explora el espacio con Airflow y certifícate
You don't have access to this class
Keep learning! Join and start boosting your career
If you already have an account,
Contributions 8
Questions 2
Sort by:
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ó
Task actions:
- Past (horizontal): marca la misma tarea en ejecuciones previas.
- Future (horizontal): marca la misma tarea en ejecuciones posteriores.
- Upstream (vertical). marca las tareas antecesoras en una ejecución.
- Downstream (vertical): marca las tareas predecesoras en una ejecución.
Seria importante que tambien se pueden hacer skip de tareas pero eso seguramente lo veremos en la clase del branch operator
En las nuevas versiones se habilitan después de darle clear las opciones de esta clase
![]()
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 
En Apache Airflow, puedes realizar diversas acciones relacionadas con tareas. Aquí tienes algunas acciones comunes en español:
1. **Crear Tarea**: Crear una nueva tarea definiendo su DAG (Directed Acyclic Graph) y configurando sus parámetros.
2. **Ver Tarea**: Ver los detalles de una tarea específica proporcionando su ID o nombre.
3. **Actualizar Tarea**: Editar los detalles de una tarea existente, como el nombre, la dependencia, la configuración o el código Python asociado.
4. **Eliminar Tarea**: Eliminar una tarea proporcionando su ID o nombre.
5. **Marcar como Completada**: Marcado una tarea como completada tras su ejecución.
6. **Listar Tareas**: Mostrar una lista de todas las tareas o filtrar según criterios como estado, prioridad o fecha de vencimiento.
7. **Buscar Tareas**: Buscar tareas usando palabras clave o filtros específicos como estado, categoría o fecha de vencimiento.
Si necesitas realizar alguna acción específica, no dudes en pedir ayuda.
Want to see more contributions, questions and answers from the community?