diff --git a/airflow/www/views.py b/airflow/www/views.py index c3bbe9efc008..32eccc0206c1 100644 --- a/airflow/www/views.py +++ b/airflow/www/views.py @@ -1435,10 +1435,10 @@ def failed(self): execution_date = request.form.get('execution_date') confirmed = request.form.get('confirmed') == "true" - upstream = request.form.get('upstream') == "true" - downstream = request.form.get('downstream') == "true" - future = request.form.get('future') == "true" - past = request.form.get('past') == "true" + upstream = request.form.get('failed_upstream') == "true" + downstream = request.form.get('failed_downstream') == "true" + future = request.form.get('failed_future') == "true" + past = request.form.get('failed_past') == "true" return self._mark_task_instance_state(dag_id, task_id, origin, execution_date, confirmed, upstream, downstream, @@ -1455,10 +1455,10 @@ def success(self): execution_date = request.form.get('execution_date') confirmed = request.form.get('confirmed') == "true" - upstream = request.form.get('upstream') == "true" - downstream = request.form.get('downstream') == "true" - future = request.form.get('future') == "true" - past = request.form.get('past') == "true" + upstream = request.form.get('success_upstream') == "true" + downstream = request.form.get('success_downstream') == "true" + future = request.form.get('success_future') == "true" + past = request.form.get('success_past') == "true" return self._mark_task_instance_state(dag_id, task_id, origin, execution_date, confirmed, upstream, downstream, diff --git a/airflow/www_rbac/views.py b/airflow/www_rbac/views.py index 1fd8f38d170f..61ec8e9f48e7 100644 --- a/airflow/www_rbac/views.py +++ b/airflow/www_rbac/views.py @@ -1166,10 +1166,10 @@ def failed(self): execution_date = request.form.get('execution_date') confirmed = request.form.get('confirmed') == "true" - upstream = request.form.get('upstream') == "true" - downstream = request.form.get('downstream') == "true" - future = request.form.get('future') == "true" - past = request.form.get('past') == "true" + upstream = request.form.get('failed_upstream') == "true" + downstream = request.form.get('failed_downstream') == "true" + future = request.form.get('failed_future') == "true" + past = request.form.get('failed_past') == "true" return self._mark_task_instance_state(dag_id, task_id, origin, execution_date, confirmed, upstream, downstream, @@ -1186,10 +1186,10 @@ def success(self): execution_date = request.form.get('execution_date') confirmed = request.form.get('confirmed') == "true" - upstream = request.form.get('upstream') == "true" - downstream = request.form.get('downstream') == "true" - future = request.form.get('future') == "true" - past = request.form.get('past') == "true" + upstream = request.form.get('success_upstream') == "true" + downstream = request.form.get('success_downstream') == "true" + future = request.form.get('success_future') == "true" + past = request.form.get('success_past') == "true" return self._mark_task_instance_state(dag_id, task_id, origin, execution_date, confirmed, upstream, downstream,