From bc7773c661f5809432c28b64e6af6e5b71410d93 Mon Sep 17 00:00:00 2001 From: frankcash Date: Tue, 31 Aug 2021 10:01:39 -0400 Subject: [PATCH] Flake8 fixes --- airflow_home/dags/elasticsearch_dag.py | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/airflow_home/dags/elasticsearch_dag.py b/airflow_home/dags/elasticsearch_dag.py index 1a9dee5..e914c26 100644 --- a/airflow_home/dags/elasticsearch_dag.py +++ b/airflow_home/dags/elasticsearch_dag.py @@ -31,13 +31,12 @@ def show_tables(): with DAG('elasticsearch_dag', start_date=datetime(2021, 8, 30), max_active_runs=1, - schedule_interval=timedelta(days=1), # https://airflow.apache.org/docs/stable/scheduler.html#dag-runs + schedule_interval=timedelta(days=1), default_args=default_args, catchup=False ) as dag: - - es_tables = PythonOperator( - task_id=f'es_print_tables', - python_callable=show_tables - ) \ No newline at end of file + es_tables = PythonOperator( + task_id='es_print_tables', + python_callable=show_tables + )