lint

dags/generate_avro_files_dag.py

@@ -3,7 +3,9 @@
 from airflow import DAG
 from kubernetes.client import models as k8s
 from stellar_etl_airflow.build_cross_dependency_task import build_cross_deps
-from stellar_etl_airflow.build_bq_generate_avro_job_task import build_bq_generate_avro_job
+from stellar_etl_airflow.build_bq_generate_avro_job_task import (
+    build_bq_generate_avro_job
+)
 from stellar_etl_airflow.default import (
     alert_sla_miss,
     get_default_dag_args,
@@ -45,8 +47,8 @@
     "offers",
     "trust_lines",
     "ttl",
-    #"history_effects",
-    #"history_operations",
+    # "history_effects",
+    # "history_operations",
 ]
 
 for table in avro_tables:
@@ -60,4 +62,3 @@
 
     wait_on_history_table >> task
     wait_on_state_table >> task
-

dags/queries/generate_avro/contract_data.sql

@@ -14,4 +14,3 @@ as (
     and closed_at < '{next_batch_run_date}'
   order by closed_at asc
 )
-

dags/queries/generate_avro/history_contract_events.sql

@@ -14,4 +14,3 @@ as (
     and closed_at < '{next_batch_run_date}'
   order by closed_at asc
 )
-

dags/queries/generate_avro/history_effects.sql

@@ -16,4 +16,3 @@ as (
     and closed_at < '{next_batch_run_date}'
   order by closed_at asc
 )
-

dags/queries/generate_avro/history_ledgers.sql

@@ -14,4 +14,3 @@ as (
     and closed_at < '{next_batch_run_date}'
   order by closed_at asc
 )
-

dags/queries/generate_avro/history_operations.sql

@@ -17,4 +17,3 @@ as (
     and closed_at < '{next_batch_run_date}'
   order by closed_at asc
 )
-

dags/queries/generate_avro/history_trades.sql

@@ -15,4 +15,3 @@ as (
     and closed_at < '{next_batch_run_date}'
   order by closed_at asc
 )
-

dags/queries/generate_avro/history_transactions.sql

@@ -14,4 +14,3 @@ as (
     and closed_at < '{next_batch_run_date}'
   order by closed_at asc
 )
-

dags/queries/generate_avro/liquidity_pools.sql

@@ -14,4 +14,3 @@ as (
     and closed_at < '{next_batch_run_date}'
   order by closed_at asc
 )
-

dags/queries/generate_avro/offers.sql

@@ -14,4 +14,3 @@ as (
     and closed_at < '{next_batch_run_date}'
   order by closed_at asc
 )
-

dags/queries/generate_avro/trust_lines.sql

@@ -14,4 +14,3 @@ as (
     and closed_at < '{next_batch_run_date}'
   order by closed_at asc
 )
-

dags/queries/generate_avro/ttl.sql

@@ -14,4 +14,3 @@ as (
     and closed_at < '{next_batch_run_date}'
   order by closed_at asc
 )
-