Browse Source

minor fix

Avik Datta 4 years ago
parent
commit
dc9076c05c
1 changed files with 1 additions and 2 deletions
  1. 1 2
      dags/dag2_disk_usage.py

+ 1 - 2
dags/dag2_disk_usage.py

@@ -1,7 +1,6 @@
 from datetime import timedelta
 
-import airflow
-from airflow import DAG,Variable
+from airflow.models import DAG,Variable
 from airflow.operators.bash_operator import BashOperator
 from airflow.contrib.operators.ssh_operator import SSHOperator
 from airflow.contrib.hooks.ssh_hook import SSHHook