Hotfix/reingest full parts to fix partial load (#205)

* temporarily reload larger range

* check complete blocks for max partition instead of arbitrary range

* use source

.gitignore

@@ -14,4 +14,5 @@ logs/
 .history/
 **/.DS_Store
 .vscode/
-.env
+.env
+dbt-env/

models/silver/silver__transactions.sql

@@ -57,7 +57,7 @@ WITH pre_final AS (
         SELECT 
             MAX(_partition_id)
         FROM 
-            {{ ref('streamline__complete_block_txs') }}
+            {{ source('solana_streamline','complete_block_txs') }}
     )
 -- AND t._inserted_timestamp > (
 --     SELECT

models/silver/silver__votes.sql

@@ -49,7 +49,7 @@ WITH pre_final AS (
             SELECT 
                 MAX(_partition_id)
             FROM 
-                {{ ref('streamline__complete_block_txs') }}
+                {{ source('solana_streamline','complete_block_txs') }}
         )
     -- AND 
     --     t._inserted_timestamp > (

models/sources.yml

@@ -53,4 +53,8 @@ sources:
     schema: silver
     tables:
       - name: nft_sales_solport
-      - name: nft_sales_magic_eden_v1
+      - name: nft_sales_magic_eden_v1
+  - name: solana_streamline
+    schema: streamline
+    tables:
+      - name: complete_block_txs