diff --git a/dags.py b/dags.py index c0af3e4e4468588ded6b7e89dd03359733ff8a50..5f6f18d71c091f588b1e48d37bed7cc45855c373 100644 --- a/dags.py +++ b/dags.py @@ -7,11 +7,6 @@ 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'