hard20 pts · first answer countsairflowairflow-trigger-rulesairflow-monitoring

Failed task but the run is green

transform fails, and then cleanup (trigger_rule="all_done") runs and succeeds. cleanup is the only leaf task. What is the DAG run state?

extract >> transform >> cleanup  # cleanup uses all_done

A.Failed, because transform failedB.Running until someone clears transformC.Upstream failedD.Success, because the only leaf succeeded

Discussion 0

Join free to post in the discussion.