PR fixes

models/bronze/backfill/bronze__checkpoints_backfill.sql

@@ -13,4 +13,4 @@ FROM
     ) }}
 WHERE
     epoch <= 629
-    AND checkpoint_number < 96605300 {# AND epoch = 628 #}
+    AND VALUE: sequence_number :: INT < 96605300

models/bronze/backfill/bronze__events_backfill.sql

@@ -9,8 +9,8 @@ SELECT
 FROM
     {{ source(
         'bronze_streamline',
-        'events_backfill'
+        'events'
     ) }}
 WHERE
     epoch <= 629
-    AND VALUE: checkpoint :: INT < 96605300 {# AND epoch = 628 #}
+    AND VALUE: checkpoint :: INT < 96605300

models/bronze/backfill/bronze__transactions_backfill.sql

@@ -7,7 +7,10 @@ SELECT
     epoch,
     DATA
 FROM
-    {{ source('bronze_streamline', 'transactions_backfill') }}
+    {{ source(
+        'bronze_streamline',
+        'transactions_backfill'
+    ) }}
 WHERE
     epoch <= 629
-    AND checkpoint_number < 96605300
+    AND VALUE: checkpoint :: INT < 96605300

models/silver/core/backfill/silver__checkpoints_backfill.sql

@@ -19,7 +19,7 @@ SELECT
     value_json :previous_checkpoint_digest :: STRING previous_digest,
     value_json :network_total_transaction :: STRING network_total_transactions,
     value_json :validator_signature :: STRING AS validator_signature,
-    value_json :total_transactions :: INT AS tx_count,
+    value_json :total_transaction_blocks :: INT AS tx_count,
     SYSDATE() AS inserted_timestamp,
     '{{ invocation_id }}' AS _invocation_id
 FROM

models/silver/core/backfill/silver__transaction_blocks_backfill.sql

@@ -23,8 +23,11 @@ SELECT
     value_json: transaction_digest :: STRING AS tx_digest,
     value_json: "transaction_kind" :: STRING AS tx_kind,
     value_json :"sender" :: STRING AS tx_sender,
-    transaction_json :"data" [0] :"intent_message" :"intent" :"version" :: STRING AS message_version,
-    -- TBD if this is real
+    LOWER(
+        object_keys(
+            transaction_json :"data" [0] :"intent_message" :value
+        ) [0]
+    ) :: STRING AS message_version,
     CASE
         WHEN efx_json :"V2" :"status" = 'Success' THEN TRUE
         ELSE FALSE

models/silver/core/backfill/silver__transactions_backfill.sql

@@ -34,7 +34,11 @@ SELECT
     value_json: transaction_digest :: STRING AS tx_digest,
     value_json: "transaction_kind" :: STRING AS tx_kind,
     value_json :"sender" :: STRING AS tx_sender,
-    transaction_json :"data" [0] :"intent_message" :"intent" :"version" :: STRING AS message_version,
+    LOWER(
+        object_keys(
+            transaction_json :"data" [0] :"intent_message" :value
+        ) [0]
+    ) :: STRING AS message_version,
     CASE
         WHEN efx_json :"V2" :"status" = 'Success' THEN TRUE
         ELSE FALSE

models/sources.yml

@@ -3,13 +3,14 @@ version: 2
 sources:
   - name: bronze_streamline
     database: streamline
-    schema: "{{ 'sui' if target.database == 'SUI' else 'sui_dev' }}"
+    schema: sui
+    # "{{ 'sui' if target.database == 'SUI' else 'sui_dev' }}"
     tables:
       - name: checkpoints
       - name: transactions
       - name: checkpoints_backfill
       - name: transactions_backfill
-      - name: events_backfill
+      - name: events
  
   - name: crosschain
     database: "{{ 'crosschain' if target.database == 'SUI' else 'crosschain_dev' }}"