#1115 bashoperator fix

CityofToronto · Dec 17, 2024 · 86668b5 · 86668b5
1 parent 2b19c9a
commit 86668b5
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/dags/log_cleanup.py b/dags/log_cleanup.py
@@ -16,7 +16,7 @@
 AIRFLOW_TASKS_LIB = os.path.join(AIRFLOW_TASKS, 'lib')
 
 from airflow.configuration import conf
-from airflow.operators.bash_operator import BashOperator
+from airflow.operators.bash import BashOperator
 from airflow.models import Variable 
 
 dag_name = 'log_cleanup'

diff --git a/dags/pull_interventions_dag.py b/dags/pull_interventions_dag.py
@@ -8,7 +8,7 @@
 import pendulum
 from airflow import DAG
 from datetime import timedelta
-from airflow.operators.bash_operator import BashOperator
+from airflow.operators.bash import BashOperator
 from airflow.models import Variable 
 
 repo_path = os.path.abspath(os.path.dirname(os.path.dirname(os.path.realpath(__file__))))