diff --git a/models/silver/core/streamline/silver__streamline_collections.sql b/models/silver/core/streamline/silver__streamline_collections.sql
index 0594d88..1e89a6a 100644
--- a/models/silver/core/streamline/silver__streamline_collections.sql
+++ b/models/silver/core/streamline/silver__streamline_collections.sql
@@ -30,6 +30,6 @@ WHERE
     {{ ref('bronze__streamline_fr_collections') }}
 {% endif %}
 
-qualify(ROW_NUMBER() over (PARTITION BY block_number
+qualify(ROW_NUMBER() over (PARTITION BY collection_id
 ORDER BY
     _inserted_timestamp DESC)) = 1
diff --git a/models/silver/core/streamline/silver__streamline_transaction_results.sql b/models/silver/core/streamline/silver__streamline_transaction_results.sql
index 529d889..511475d 100644
--- a/models/silver/core/streamline/silver__streamline_transaction_results.sql
+++ b/models/silver/core/streamline/silver__streamline_transaction_results.sql
@@ -18,7 +18,7 @@ SELECT
 FROM
 
 {% if is_incremental() %}
-{{ ref('bronze__streamline_transaction_results') }} AS t
+{{ ref('bronze__streamline_transaction_results') }}
 WHERE
     _inserted_timestamp >= (
         SELECT
@@ -27,9 +27,9 @@ WHERE
             {{ this }}
     )
 {% else %}
-    {{ ref('bronze__streamline_fr_transaction_results') }} AS t
+    {{ ref('bronze__streamline_fr_transaction_results') }}
 {% endif %}
 
-qualify(ROW_NUMBER() over (PARTITION BY t.block_number
+qualify(ROW_NUMBER() over (PARTITION BY tx_id
 ORDER BY
-    t._inserted_timestamp DESC)) = 1
+    _inserted_timestamp DESC)) = 1
diff --git a/models/silver/core/streamline/silver__streamline_transactions.sql b/models/silver/core/streamline/silver__streamline_transactions.sql
index ee0242b..2bdefc9 100644
--- a/models/silver/core/streamline/silver__streamline_transactions.sql
+++ b/models/silver/core/streamline/silver__streamline_transactions.sql
@@ -35,6 +35,6 @@ WHERE
     {{ ref('bronze__streamline_fr_transactions') }}
 {% endif %}
 
-qualify(ROW_NUMBER() over (PARTITION BY block_number
+qualify(ROW_NUMBER() over (PARTITION BY tx_id
 ORDER BY
     _inserted_timestamp DESC)) = 1