Flake8 fixes

frankcash · Aug 31, 2021 · bc7773c · bc7773c
1 parent 1086655
commit bc7773c
Showing 1 changed file with 5 additions and 6 deletions.
diff --git 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
-        )
+    es_tables = PythonOperator(
+        task_id='es_print_tables',
+        python_callable=show_tables
+    )