flip/solana-models
1
0
Fork 0
mirror of https://github.com/FlipsideCrypto/solana-models.git synced 2026-02-06 09:41:44 +00:00
Code Issues Actions 14 Packages Projects Releases Wiki Activity

Migrate compressed mint calls to streamline 2.0 (#739)

Browse Source 
* fix batch size for udf

* update usage to v2
This commit is contained in:
desmond-hui 2024-12-17 07:23:12 -08:00 committed by GitHub
parent b4a953cbf9
commit 63dc6591e4
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
5 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
macros/helpers/nft_compressed_mints_backfill_helpers.sql
View File

@ -82,7 +82,7 @@
)
SELECT
ARRAY_AGG(request) AS batch_request,
streamline.udf_decode_compressed_mint_change_logs(batch_request) AS responses,
streamline.udf_decode_compressed_mint_change_logs_v2(batch_request) AS responses,
MIN(event_inserted_timestamp) AS start_inserted_timestamp,
MAX(event_inserted_timestamp) AS end_inserted_timestamp,
concat_ws(

1
macros/streamline/streamline_udfs.sql
View File

@ -82,6 +82,7 @@
CREATE
OR REPLACE EXTERNAL FUNCTION streamline.udf_decode_compressed_mint_change_logs_v2("JSON" ARRAY)
returns VARIANT
max_batch_rows = 1
api_integration =
{% if target.database == 'SOLANA' -%}
AWS_SOLANA_API_PROD_V2

2
models/bronze/bronze_api/bronze_api__parse_compressed_nft_mints.sql
View File

@ -96,7 +96,7 @@ base AS (
)
SELECT
ARRAY_AGG(request) AS batch_request,
streamline.udf_decode_compressed_mint_change_logs(batch_request) AS responses,
streamline.udf_decode_compressed_mint_change_logs_v2(batch_request) AS responses,
MIN(event_inserted_timestamp) AS start_inserted_timestamp,
MAX(event_inserted_timestamp) AS end_inserted_timestamp,
concat_ws(

2
models/bronze/bronze_api/bronze_api__parse_compressed_nft_sales_magic_eden.sql
View File

@ -81,7 +81,7 @@ base AS (
)
SELECT
ARRAY_AGG(request) AS batch_request,
streamline.udf_decode_compressed_mint_change_logs(batch_request) AS responses,
streamline.udf_decode_compressed_mint_change_logs_v2(batch_request) AS responses,
MIN(decoded_inserted_timestamp) AS start_inserted_timestamp,
MAX(decoded_inserted_timestamp) AS end_inserted_timestamp,
SYSDATE() AS _inserted_timestamp,

2
models/bronze/bronze_api/bronze_api__parse_compressed_nft_sales_solsniper.sql
View File

@ -81,7 +81,7 @@ base AS (
)
SELECT
ARRAY_AGG(request) AS batch_request,
streamline.udf_decode_compressed_mint_change_logs(batch_request) AS responses,
streamline.udf_decode_compressed_mint_change_logs_v2(batch_request) AS responses,
MIN(decoded_inserted_timestamp) AS start_inserted_timestamp,
MAX(decoded_inserted_timestamp) AS end_inserted_timestamp,
SYSDATE() AS _inserted_timestamp,