diff --git a/dags.py b/dags.py
index b37fe9d48c90161c95b0bd398902b1fe2f546bef..dc1939231abcc3b02eebb6efac8f4f6356a872c1 100644
--- a/dags.py
+++ b/dags.py
@@ -7,6 +7,10 @@ from airflow.operators.bash import BashOperator
 
 from airflow.providers.apache.spark.operators.spark_submit import SparkSubmitOperator
 
+from minio import Minio
+from minio.error import ResponseError
+from airflow.operators.python import PythonOperator
+
 
 repo_home = '/opt/airflow/dags/repo'