Steve Jacobs created AIRFLOW-3344: ------------------------------------- Summary: Airflow DAG object clear function does not clear tasks in the upstream_failed state when only_failed=True Key: AIRFLOW-3344 URL: https://issues.apache.org/jira/browse/AIRFLOW-3344 Project: Apache Airflow Issue Type: Bug Components: DAG Affects Versions: 1.10.0, 1.9.0, 1.8.2 Reporter: Steve Jacobs
When using the airflow clear command from the cli, you can pass an argument --only_failed to clear only failed tasks. This will clear ONLY tasks with the state failed, and not tasks with the state upstream_failed, causing any clear to still fail the dag_run if any upstream tasks are failed. Since one_failed as a trigger rule also checks for upstream_failed tasks, it seems consistent that this should also clear upstream_failed tasks. The relevant code change necessary is here: {code:java} if only_failed: tis = tis.filter(TI.state == State.FAILED) {code} to {code:java} if only_failed: tis = tis.filter(TI.state.in_([State.FAILED, State.UPSTREAM_FAILED])) {code} in models.py -- This message was sent by Atlassian JIRA (v7.6.3#76005)