Task Actions

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.

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