diff --git a/dags/log_cleanup.py b/dags/log_cleanup.py
index e98269dd7..d5de0b597 100644
--- 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
index c3c24febd..d1237a1f1 100644
--- 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__))))