diff --git a/models/silver/silver__pool_block_statistics.sql b/models/silver/silver__pool_block_statistics.sql
index 67fb4fb..e64c1e9 100644
--- a/models/silver/silver__pool_block_statistics.sql
+++ b/models/silver/silver__pool_block_statistics.sql
@@ -488,6 +488,7 @@ joined AS (
     total_stake * synth_depth / ((asset_depth * 2) - synth_depth) AS synth_units,
     CASE
       WHEN total_stake = 0 THEN 0
+      WHEN depth_product < 0 THEN 0
       ELSE SQRT(depth_product) / (
         total_stake + synth_units
       )
diff --git a/models/silver/silver__rune_pool_deposit_events.sql b/models/silver/silver__rune_pool_deposit_events.sql
index 4d6c9ae..2c6875e 100644
--- a/models/silver/silver__rune_pool_deposit_events.sql
+++ b/models/silver/silver__rune_pool_deposit_events.sql
@@ -18,3 +18,9 @@ FROM
   {{ ref(
     'bronze__rune_pool_deposit_events'
   ) }}
+QUALIFY(
+  ROW_NUMBER() OVER (
+    PARTITION BY event_id
+    ORDER BY __HEVO__LOADED_AT DESC
+  ) = 1
+)
\ No newline at end of file
diff --git a/models/silver/silver__rune_pool_withdraw_events.sql b/models/silver/silver__rune_pool_withdraw_events.sql
index a451c42..8acf968 100644
--- a/models/silver/silver__rune_pool_withdraw_events.sql
+++ b/models/silver/silver__rune_pool_withdraw_events.sql
@@ -22,3 +22,9 @@ FROM
   {{ ref(
     'bronze__rune_pool_withdraw_events'
   ) }}
+QUALIFY(
+  ROW_NUMBER() OVER (
+    PARTITION BY event_id
+    ORDER BY __HEVO__LOADED_AT DESC
+  ) = 1
+)
\ No newline at end of file
diff --git a/models/silver/silver__scheduled_outbound_events.sql b/models/silver/silver__scheduled_outbound_events.sql
index 953f608..83aec6e 100644
--- a/models/silver/silver__scheduled_outbound_events.sql
+++ b/models/silver/silver__scheduled_outbound_events.sql
@@ -26,3 +26,9 @@ SELECT
   ) AS _INSERTED_TIMESTAMP
 FROM
   {{ ref('bronze__scheduled_outbound_events') }}
+QUALIFY(
+  ROW_NUMBER() OVER (
+    PARTITION BY event_id
+    ORDER BY __HEVO__LOADED_AT DESC
+  ) = 1
+)
\ No newline at end of file
diff --git a/models/silver/silver__stake_events.sql b/models/silver/silver__stake_events.sql
index b22788d..59c7575 100644
--- a/models/silver/silver__stake_events.sql
+++ b/models/silver/silver__stake_events.sql
@@ -22,6 +22,6 @@ SELECT
   ) AS _INSERTED_TIMESTAMP
 FROM
   {{ ref('bronze__stake_events') }}
-  qualify(ROW_NUMBER() over(PARTITION BY event_id, pool, rune_tx, asset_chain, stake_units, rune_addr, asset_tx, asset_addr, block_timestamp
+  qualify(ROW_NUMBER() over(PARTITION BY pool, rune_tx, asset_chain, stake_units, rune_addr, asset_tx, asset_addr, block_timestamp
 ORDER BY
   __HEVO__INGESTED_AT DESC)) = 1
diff --git a/models/silver/silver__swap_events.yml b/models/silver/silver__swap_events.yml
index 5bd381b..27882a8 100644
--- a/models/silver/silver__swap_events.yml
+++ b/models/silver/silver__swap_events.yml
@@ -20,6 +20,7 @@ models:
             - LIQ_FEE_IN_RUNE_E8
             - _DIRECTION
             - BLOCK_TIMESTAMP
+            - EVENT_ID
     columns:
       - name: TX_ID
         tests:
diff --git a/models/silver/silver__update_node_account_status_events.yml b/models/silver/silver__update_node_account_status_events.yml
index 16ef16e..a09f5f9 100644
--- a/models/silver/silver__update_node_account_status_events.yml
+++ b/models/silver/silver__update_node_account_status_events.yml
@@ -8,6 +8,7 @@ models:
             - CURRENT_STATUS
             - FORMER_STATUS
             - BLOCK_TIMESTAMP
+            - EVENT_ID
     columns:
       - name: NODE_ADDRESS
         tests:
diff --git a/models/silver/silver__withdraw_events.yml b/models/silver/silver__withdraw_events.yml
index 20241cf..64035c1 100644
--- a/models/silver/silver__withdraw_events.yml
+++ b/models/silver/silver__withdraw_events.yml
@@ -12,6 +12,7 @@ models:
             - MEMO
             - POOL_NAME
             - BLOCK_TIMESTAMP
+            - EVENT_ID
     columns:
       - name: TX_ID
         tests: