diff --git a/airflow/jobs/scheduler_job.py b/airflow/jobs/scheduler_job.py index 4a2c1da584643c..2640f1232efe51 100644 --- a/airflow/jobs/scheduler_job.py +++ b/airflow/jobs/scheduler_job.py @@ -751,11 +751,11 @@ def _change_state_for_tis_without_dagrun(self, changed manually. :param old_states: examine TaskInstances in this state - :type old_state: list[airflow.utils.state.State] + :type old_states: list[airflow.utils.state.State] :param new_state: set TaskInstances to this state :type new_state: airflow.utils.state.State :param simple_dag_bag: TaskInstances associated with DAGs in the - simple_dag_bag and with states in the old_state will be examined + simple_dag_bag and with states in the old_states will be examined :type simple_dag_bag: airflow.utils.dag_processing.SimpleDagBag """ tis_changed = 0