Task Actions

Clase 19 de 29 • Curso de Fundamentos de Apache Airflow

Clase anteriorSiguiente clase

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

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.

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.

Bryan Carvajal

student•

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ó

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.

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

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

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

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.