add snapshot state task

dags/dbt_sdf_marts_dag.py

@@ -47,6 +47,7 @@
 partnership_assets_task = dbt_task(dag, tag="partnership_assets")
 history_assets = dbt_task(dag, tag="history_assets")
 soroban = dbt_task(dag, tag="soroban")
+snapshot_state = dbt_task(dag, tag="snapshot_state")
 
 elementary = elementary_task(dag, "dbt_sdf_marts")
 
@@ -66,6 +67,7 @@
 wait_on_dbt_enriched_base_tables >> partnership_assets_task
 wait_on_dbt_enriched_base_tables >> history_assets
 wait_on_dbt_enriched_base_tables >> soroban
+wait_on_dbt_enriched_base_tables >> snapshot_state
 
 mgi_task >> elementary
 liquidity_providers_task >> elementary
@@ -79,3 +81,4 @@
 history_assets >> elementary
 soroban >> elementary
 liquidity_pool_trade_volume_task >> elementary
+snapshot_state >> elementary