You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
From definition of the state enums, task instance states can be grouped into three categories:
Terminal States
success
failed
skipped
removed (sort of, because a task instance can be reset to "none" state when it becomes available again during DAG run)
Intermediate States
scheduled
queued
restarting
up_for_retry
up_for_reschedule
upstream_failed
deferred
Other States
running (occupied by executor/worker)
none (not processed by scheduler yet)
Other states seems to be reasonable in their corresponding category, but why is "upstream_failed" placed inside of "Intermediate States" category? A task enters this state when any of the required upstream tasks failed, and it won't be updated by the scheduler unless the failed states are cleared for another run.
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
-
Currently I'm reworking on the task lifecycle graph to get it up to the latest version of Airflow:
From definition of the state enums, task instance states can be grouped into three categories:
Terminal States
Intermediate States
Other States
Other states seems to be reasonable in their corresponding category, but why is "upstream_failed" placed inside of "Intermediate States" category? A task enters this state when any of the required upstream tasks failed, and it won't be updated by the scheduler unless the failed states are cleared for another run.
Beta Was this translation helpful? Give feedback.
All reactions