fixup! fixup! fixup! Update base_executor.py

apache · Jul 6, 2020 · 694a6e3 · 694a6e3
1 parent 9e5a4b6
commit 694a6e3
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/airflow/models/taskinstance.py b/airflow/models/taskinstance.py
@@ -52,6 +52,7 @@
 from airflow.settings import STORE_SERIALIZED_DAGS
 from airflow.stats import Stats
 from airflow.ti_deps.dep_context import DepContext
+from airflow.ti_deps.dependencies_deps import REQUEUEABLE_DEPS, RUNNING_DEPS
 from airflow.utils import timezone
 from airflow.utils.email import send_email
 from airflow.utils.helpers import is_container
@@ -883,8 +884,6 @@ def check_and_change_state_before_execution(    # pylint: disable=too-many-argum
         :return: whether the state was changed to running or not
         :rtype: bool
         """
-        # Avoid Circular dependency
-        from airflow.ti_deps.dependencies_deps import REQUEUEABLE_DEPS, RUNNING_DEPS
 
         task = self.task
         self.refresh_from_task(task, pool_override=pool)