Reformat code

stellar · Nov 14, 2024 · c6c9b5d · c6c9b5d
1 parent 825d896
commit c6c9b5d
Show file tree

Hide file tree

Showing 2 changed files with 22 additions and 7 deletions.
diff --git a/dags/dbt_enriched_base_tables_dag.py b/dags/dbt_enriched_base_tables_dag.py
@@ -34,7 +34,9 @@
 wait_on_state_table = build_cross_deps(dag, "wait_on_state_table", "state_table_export")
 
 # DBT models to run
-enriched_history_operations_task = dbt_task(dag, tag="enriched_history_operations", operator="+")
+enriched_history_operations_task = dbt_task(
+    dag, tag="enriched_history_operations", operator="+"
+)
 current_state_task = dbt_task(dag, tag="current_state", operator="+")
 
 # DAG task graph

diff --git a/dags/dbt_stellar_marts_dag.py b/dags/dbt_stellar_marts_dag.py
@@ -38,16 +38,29 @@
     dag, tag="liquidity_pool_trade_volume", operator="+", excluded="stellar_dbt_public"
 )
 
-liquidity_providers_task = dbt_task(dag, tag="liquidity_providers", excluded="stellar_dbt_public")
-liquidity_pools_values_task = dbt_task(dag, tag="liquidity_pools_value", operator="+", excluded="stellar_dbt_public")
+liquidity_providers_task = dbt_task(
+    dag, tag="liquidity_providers", excluded="stellar_dbt_public"
+)
+liquidity_pools_values_task = dbt_task(
+    dag, tag="liquidity_pools_value", operator="+", excluded="stellar_dbt_public"
+)
 liquidity_pools_value_history_task = dbt_task(
-    dag, tag="liquidity_pools_value_history", operator="+", excluded="stellar_dbt_public"
+    dag,
+    tag="liquidity_pools_value_history",
+    operator="+",
+    excluded="stellar_dbt_public",
 )
 trade_agg_task = dbt_task(dag, tag="trade_agg", operator="+")
 fee_stats_agg_task = dbt_task(dag, tag="fee_stats")
-asset_stats_agg_task = dbt_task(dag, tag="asset_stats", operator="+", excluded="stellar_dbt_public")
-network_stats_agg_task = dbt_task(dag, tag="network_stats", excluded="stellar_dbt_public")
-partnership_assets_task = dbt_task(dag, tag="partnership_assets", operator="+", excluded="stellar_dbt_public")
+asset_stats_agg_task = dbt_task(
+    dag, tag="asset_stats", operator="+", excluded="stellar_dbt_public"
+)
+network_stats_agg_task = dbt_task(
+    dag, tag="network_stats", excluded="stellar_dbt_public"
+)
+partnership_assets_task = dbt_task(
+    dag, tag="partnership_assets", operator="+", excluded="stellar_dbt_public"
+)
 history_assets = dbt_task(dag, tag="history_assets", operator="+")
 # Disable soroban tables because they're broken
 # soroban = dbt_task(dag, tag="soroban", operator="+")