Task Actions

Clase 19 de 29 • Curso de Fundamentos de Apache Airflow

Clase anteriorSiguiente clase

Marvin Avila Burgos

student•

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ó

Leonardo Carvallo

student•

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.

Rafael Alejandro Belalcázar Burbano

student•

Si, es un problema común. Según la versión, airflow puede indicarnos el error de sintaxis en el home con un warning.

Oscar Camilo Luna Feo

student•

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.

Bryan Carvajal

student•

Royer Guerrero Pinilla

student•

Seria importante que tambien se pueden hacer skip de tareas pero eso seguramente lo veremos en la clase del branch operator

Ybrahin Martinez

student•

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

Luis Ernesto Domínguez Velásquez

student•

Ya somos dos que no vemos las Task Actions en versiones actuales de Airflow.

Gino G. Viloria

student•

En las nuevas versiones se habilitan después de darle clear las opciones de esta clase

sebastian felipe herrera sanchez

student•

A pesar de que el curso el "antiguo" el conocimiento sigue vigente

César Pérez

student•

Por qué hay tres filas con las opciones de PAST, FUTURE, UPSTREAM y DOWNSTREAM?

Enrique Alexis Lopez Araujo

student•

Como lo comenta el profe desde el minuto 6:00 no ayuda a hacer la action de la tarea para:

Past: todas las instancias de la tarea en las ejecuciones anteriores al intervalo de datos más reciente del DAG
Future: todas las instancias de la tarea en las ejecuciones posteriores al intervalo de datos más reciente del DAG
Upstream: las tareas upstream en el DAG actual.
Downstream: las tareas downstream en el DAG actual.

Eso sacado directo de la documentacion oficial

ANDY GONZALEZ

student•

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?!![

Eric Bellet

teacher•

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

Mario Alexander Vargas Celis

student•

En Apache Airflow, puedes realizar diversas acciones relacionadas con tareas. Aquí tienes algunas acciones comunes en español:

Crear Tarea: Crear una nueva tarea definiendo su DAG (Directed Acyclic Graph) y configurando sus parámetros.
Ver Tarea: Ver los detalles de una tarea específica proporcionando su ID o nombre.
Actualizar Tarea: Editar los detalles de una tarea existente, como el nombre, la dependencia, la configuración o el código Python asociado.
Eliminar Tarea: Eliminar una tarea proporcionando su ID o nombre.
Marcar como Completada: Marcado una tarea como completada tras su ejecución.
Listar Tareas: Mostrar una lista de todas las tareas o filtrar según criterios como estado, prioridad o fecha de vencimiento.
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.

Task Actions

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