AN-3935/backfill views (#208)

* archive parameterized model

* create views for each network ver

* network version views

* newline

* switch tx results realtime back to us-east-1

* del blocks history mainnet23

* add backfill step to streamline GHA

* newline

* rm dup WHERE

* upd name and del dup where from template
This commit is contained in:
Jack Forgash 2023-10-19 13:12:13 -06:00 committed by GitHub
parent 19bbac48a2
commit 856ac1629f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
116 changed files with 4373 additions and 56 deletions

View File

@ -44,11 +44,7 @@ jobs:
- name: Run DBT Realtime
run: |
dbt run -s 1+streamline__get_blocks_realtime --vars '{"STREAMLINE_INVOKE_STREAMS": True, "STREAMLINE_RUN_HISTORY": True}'
- name: Run DBT History Jobs - Mainnet22
run: |
dbt run -s 1+streamline__get_blocks_history --vars '{"STREAMLINE_INVOKE_STREAMS": True, "node_url": "access-001.mainnet22.nodes.onflow.org:9000", "start_block": 47169687, "end_block": 55114466}'
- name: Run DBT History Jobs - Mainnet19
- name: Run Backfill Models
run: |
dbt run -s 1+streamline__get_blocks_history --vars '{"STREAMLINE_INVOKE_STREAMS": True, "node_url": "access-001.mainnet19.nodes.onflow.org:9000", "start_block": 35858811, "end_block": 40171633}'
dbt run -s models/silver/streamline/core/history/blocks --vars '{"STREAMLINE_INVOKE_STREAMS": True, "STREAMLINE_RUN_HISTORY": True}'

View File

@ -44,3 +44,7 @@ jobs:
- name: Run DBT Realtime
run: |
dbt run -s 1+streamline__get_collections_realtime --vars '{"STREAMLINE_INVOKE_STREAMS": True, "STREAMLINE_RUN_HISTORY": True}'
- name: Run Backfill Models
run: |
dbt run -s models/silver/streamline/core/history/collections --vars '{"STREAMLINE_INVOKE_STREAMS": True, "STREAMLINE_RUN_HISTORY": True}'

View File

@ -1,37 +0,0 @@
name: dbt_run_streamline_hourly
run-name: dbt_run_streamline_hourly
on:
workflow_dispatch:
# disabling 10/10/23 moving workflow to dbt_run_scheduled
# schedule:
# Runs "every hour" (see https://crontab.guru)
# - cron: '0 */1 * * *'
env:
USE_VARS: "${{ vars.USE_VARS }}"
DBT_PROFILES_DIR: "${{ vars.DBT_PROFILES_DIR }}"
DBT_VERSION: "${{ vars.DBT_VERSION }}"
ACCOUNT: "${{ vars.ACCOUNT }}"
ROLE: "${{ vars.ROLE }}"
USER: "${{ vars.USER }}"
PASSWORD: "${{ secrets.PASSWORD }}"
REGION: "${{ vars.REGION }}"
DATABASE: "${{ vars.DATABASE }}"
WAREHOUSE: "${{ vars.WAREHOUSE }}"
SCHEMA: "${{ vars.SCHEMA }}"
concurrency:
group: ${{ github.workflow }}
jobs:
called_workflow_template:
uses: FlipsideCrypto/analytics-workflow-templates/.github/workflows/dbt_run_template.yml@main
with:
dbt_command: >
dbt run-operation stage_external_sources --vars "ext_full_refresh: true";
dbt seed;
dbt run -s tag:streamline_load tag:streamline_complete
environment: workflow_prod
warehouse: ${{ vars.WAREHOUSE }}
secrets: inherit

View File

@ -44,3 +44,7 @@ jobs:
- name: Run DBT Realtime
run: |
dbt run -s 1+streamline__get_transaction_results_realtime --vars '{"STREAMLINE_INVOKE_STREAMS": True, "STREAMLINE_RUN_HISTORY": True, "producer_batch_size": 60000, "worker_batch_size": 2000}'
- name: Run Backfill Models
run: |
dbt run -s models/silver/streamline/core/history/transaction_results --vars '{"STREAMLINE_INVOKE_STREAMS": True, "STREAMLINE_RUN_HISTORY": True}'

View File

@ -44,3 +44,7 @@ jobs:
- name: Run DBT Realtime
run: |
dbt run -s 1+streamline__get_transactions_realtime --vars '{"STREAMLINE_INVOKE_STREAMS": True, "STREAMLINE_RUN_HISTORY": True}'
- name: Run Backfill Models
run: |
dbt run -s models/silver/streamline/core/history/transactions --vars '{"STREAMLINE_INVOKE_STREAMS": True, "STREAMLINE_RUN_HISTORY": True}'

View File

@ -1,7 +1,7 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet22.nodes.onflow.org:9000','external_table', 'blocks', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.candidate7.nodes.onflow.org:9000','external_table', 'blocks_candidate_07', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
@ -14,7 +14,7 @@ WITH blocks AS (
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number as block_height
block_number AS block_height
FROM
{{ ref("streamline__complete_get_blocks") }}
)
@ -28,6 +28,7 @@ SELECT
FROM
blocks
WHERE
block_height BETWEEN 47169687 AND 55114466 -- Mainnet22 block range
block_height BETWEEN 4132133
AND 4972986
ORDER BY
block_height ASC
block_height ASC

View File

@ -0,0 +1,34 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.candidate8.nodes.onflow.org:9000','external_table', 'blocks_candidate_08', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_blocks") }}
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_block_by_height',
'block_height', block_height,
'method_params', OBJECT_CONSTRUCT('height', block_height)
) AS request
FROM
blocks
WHERE
block_height BETWEEN 4972987
AND 6483245
ORDER BY
block_height ASC

View File

@ -0,0 +1,34 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.candidate9.nodes.onflow.org:9000','external_table', 'blocks_candidate_09', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_blocks") }}
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_block_by_height',
'block_height', block_height,
'method_params', OBJECT_CONSTRUCT('height', block_height)
) AS request
FROM
blocks
WHERE
block_height BETWEEN 6483246
AND 7601062
ORDER BY
block_height ASC

View File

@ -0,0 +1,34 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet1.nodes.onflow.org:9000','external_table', 'blocks_mainnet_01', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_blocks") }}
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_block_by_height',
'block_height', block_height,
'method_params', OBJECT_CONSTRUCT('height', block_height)
) AS request
FROM
blocks
WHERE
block_height BETWEEN 7601063
AND 8742958
ORDER BY
block_height ASC

View File

@ -0,0 +1,34 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet2.nodes.onflow.org:9000','external_table', 'blocks_mainnet_02', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_blocks") }}
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_block_by_height',
'block_height', block_height,
'method_params', OBJECT_CONSTRUCT('height', block_height)
) AS request
FROM
blocks
WHERE
block_height BETWEEN 8742959
AND 9737132
ORDER BY
block_height ASC

View File

@ -0,0 +1,34 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet3.nodes.onflow.org:9000','external_table', 'blocks_mainnet_03', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_blocks") }}
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_block_by_height',
'block_height', block_height,
'method_params', OBJECT_CONSTRUCT('height', block_height)
) AS request
FROM
blocks
WHERE
block_height BETWEEN 9737133
AND 9992019
ORDER BY
block_height ASC

View File

@ -0,0 +1,34 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet4.nodes.onflow.org:9000','external_table', 'blocks_mainnet_04', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_blocks") }}
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_block_by_height',
'block_height', block_height,
'method_params', OBJECT_CONSTRUCT('height', block_height)
) AS request
FROM
blocks
WHERE
block_height BETWEEN 9992020
AND 12020336
ORDER BY
block_height ASC

View File

@ -0,0 +1,34 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet5.nodes.onflow.org:9000','external_table', 'blocks_mainnet_05', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_blocks") }}
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_block_by_height',
'block_height', block_height,
'method_params', OBJECT_CONSTRUCT('height', block_height)
) AS request
FROM
blocks
WHERE
block_height BETWEEN 12020337
AND 12609236
ORDER BY
block_height ASC

View File

@ -0,0 +1,34 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet6.nodes.onflow.org:9000','external_table', 'blocks_mainnet_06', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_blocks") }}
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_block_by_height',
'block_height', block_height,
'method_params', OBJECT_CONSTRUCT('height', block_height)
) AS request
FROM
blocks
WHERE
block_height BETWEEN 12609237
AND 13404173
ORDER BY
block_height ASC

View File

@ -0,0 +1,34 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet7.nodes.onflow.org:9000','external_table', 'blocks_mainnet_07', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_blocks") }}
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_block_by_height',
'block_height', block_height,
'method_params', OBJECT_CONSTRUCT('height', block_height)
) AS request
FROM
blocks
WHERE
block_height BETWEEN 13404174
AND 13950741
ORDER BY
block_height ASC

View File

@ -0,0 +1,34 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet8.nodes.onflow.org:9000','external_table', 'blocks_mainnet_08', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_blocks") }}
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_block_by_height',
'block_height', block_height,
'method_params', OBJECT_CONSTRUCT('height', block_height)
) AS request
FROM
blocks
WHERE
block_height BETWEEN 13950742
AND 14892103
ORDER BY
block_height ASC

View File

@ -0,0 +1,34 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet9.nodes.onflow.org:9000','external_table', 'blocks_mainnet_09', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_blocks") }}
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_block_by_height',
'block_height', block_height,
'method_params', OBJECT_CONSTRUCT('height', block_height)
) AS request
FROM
blocks
WHERE
block_height BETWEEN 14892104
AND 15791890
ORDER BY
block_height ASC

View File

@ -0,0 +1,34 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet10.nodes.onflow.org:9000','external_table', 'blocks_mainnet_10', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_blocks") }}
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_block_by_height',
'block_height', block_height,
'method_params', OBJECT_CONSTRUCT('height', block_height)
) AS request
FROM
blocks
WHERE
block_height BETWEEN 15791891
AND 16755601
ORDER BY
block_height ASC

View File

@ -0,0 +1,34 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet11.nodes.onflow.org:9000','external_table', 'blocks_mainnet_11', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_blocks") }}
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_block_by_height',
'block_height', block_height,
'method_params', OBJECT_CONSTRUCT('height', block_height)
) AS request
FROM
blocks
WHERE
block_height BETWEEN 16755602
AND 17544522
ORDER BY
block_height ASC

View File

@ -0,0 +1,34 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet12.nodes.onflow.org:9000','external_table', 'blocks_mainnet_12', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_blocks") }}
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_block_by_height',
'block_height', block_height,
'method_params', OBJECT_CONSTRUCT('height', block_height)
) AS request
FROM
blocks
WHERE
block_height BETWEEN 17544523
AND 18587477
ORDER BY
block_height ASC

View File

@ -0,0 +1,34 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet13.nodes.onflow.org:9000','external_table', 'blocks_mainnet_13', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_blocks") }}
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_block_by_height',
'block_height', block_height,
'method_params', OBJECT_CONSTRUCT('height', block_height)
) AS request
FROM
blocks
WHERE
block_height BETWEEN 18587478
AND 19050752
ORDER BY
block_height ASC

View File

@ -0,0 +1,34 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet14.nodes.onflow.org:9000','external_table', 'blocks_mainnet_14', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_blocks") }}
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_block_by_height',
'block_height', block_height,
'method_params', OBJECT_CONSTRUCT('height', block_height)
) AS request
FROM
blocks
WHERE
block_height BETWEEN 19050753
AND 21291691
ORDER BY
block_height ASC

View File

@ -0,0 +1,34 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet15.nodes.onflow.org:9000','external_table', 'blocks_mainnet_15', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_blocks") }}
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_block_by_height',
'block_height', block_height,
'method_params', OBJECT_CONSTRUCT('height', block_height)
) AS request
FROM
blocks
WHERE
block_height BETWEEN 21291692
AND 23830812
ORDER BY
block_height ASC

View File

@ -0,0 +1,34 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet16.nodes.onflow.org:9000','external_table', 'blocks_mainnet_16', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_blocks") }}
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_block_by_height',
'block_height', block_height,
'method_params', OBJECT_CONSTRUCT('height', block_height)
) AS request
FROM
blocks
WHERE
block_height BETWEEN 23830813
AND 27341469
ORDER BY
block_height ASC

View File

@ -0,0 +1,34 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet17.nodes.onflow.org:9000','external_table', 'blocks_mainnet_17', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_blocks") }}
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_block_by_height',
'block_height', block_height,
'method_params', OBJECT_CONSTRUCT('height', block_height)
) AS request
FROM
blocks
WHERE
block_height BETWEEN 27341470
AND 31735954
ORDER BY
block_height ASC

View File

@ -0,0 +1,34 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet18.nodes.onflow.org:9000','external_table', 'blocks_mainnet_18', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_blocks") }}
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_block_by_height',
'block_height', block_height,
'method_params', OBJECT_CONSTRUCT('height', block_height)
) AS request
FROM
blocks
WHERE
block_height BETWEEN 31735955
AND 35858810
ORDER BY
block_height ASC

View File

@ -0,0 +1,34 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet19.nodes.onflow.org:9000','external_table', 'blocks_mainnet_19', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_blocks") }}
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_block_by_height',
'block_height', block_height,
'method_params', OBJECT_CONSTRUCT('height', block_height)
) AS request
FROM
blocks
WHERE
block_height BETWEEN 35858811
AND 40171633
ORDER BY
block_height ASC

View File

@ -0,0 +1,34 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet20.nodes.onflow.org:9000','external_table', 'blocks_mainnet_20', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_blocks") }}
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_block_by_height',
'block_height', block_height,
'method_params', OBJECT_CONSTRUCT('height', block_height)
) AS request
FROM
blocks
WHERE
block_height BETWEEN 40171634
AND 44950206
ORDER BY
block_height ASC

View File

@ -0,0 +1,34 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet21.nodes.onflow.org:9000','external_table', 'blocks_mainnet_21', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_blocks") }}
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_block_by_height',
'block_height', block_height,
'method_params', OBJECT_CONSTRUCT('height', block_height)
) AS request
FROM
blocks
WHERE
block_height BETWEEN 44950207
AND 47169686
ORDER BY
block_height ASC

View File

@ -0,0 +1,34 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet22.nodes.onflow.org:9000','external_table', 'blocks_mainnet_22', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_blocks") }}
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_block_by_height',
'block_height', block_height,
'method_params', OBJECT_CONSTRUCT('height', block_height)
) AS request
FROM
blocks
WHERE
block_height BETWEEN 47169687
AND 55114466
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.candidate7.nodes.onflow.org:9000','external_table', 'transactions_candidate_07', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 4132133
AND 4972986
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.candidate8.nodes.onflow.org:9000','external_table', 'transactions_candidate_08', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 4972987
AND 6483245
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.candidate9.nodes.onflow.org:9000','external_table', 'transactions_candidate_09', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 6483246
AND 7601062
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet1.nodes.onflow.org:9000','external_table', 'transactions_mainnet_01', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 7601063
AND 8742958
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet2.nodes.onflow.org:9000','external_table', 'transactions_mainnet_02', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 8742959
AND 9737132
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet3.nodes.onflow.org:9000','external_table', 'transactions_mainnet_03', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 9737133
AND 9992019
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet4.nodes.onflow.org:9000','external_table', 'transactions_mainnet_04', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 9992020
AND 12020336
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet5.nodes.onflow.org:9000','external_table', 'transactions_mainnet_05', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 12020337
AND 12609236
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet6.nodes.onflow.org:9000','external_table', 'transactions_mainnet_06', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 12609237
AND 13404173
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet7.nodes.onflow.org:9000','external_table', 'transactions_mainnet_07', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 13404174
AND 13950741
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet8.nodes.onflow.org:9000','external_table', 'transactions_mainnet_08', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 13950742
AND 14892103
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet9.nodes.onflow.org:9000','external_table', 'transactions_mainnet_09', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 14892104
AND 15791890
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet10.nodes.onflow.org:9000','external_table', 'transactions_mainnet_10', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 15791891
AND 16755601
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet11.nodes.onflow.org:9000','external_table', 'transactions_mainnet_11', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 16755602
AND 17544522
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet12.nodes.onflow.org:9000','external_table', 'transactions_mainnet_12', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 17544523
AND 18587477
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet13.nodes.onflow.org:9000','external_table', 'transactions_mainnet_13', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 18587478
AND 19050752
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet14.nodes.onflow.org:9000','external_table', 'transactions_mainnet_14', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 19050753
AND 21291691
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet15.nodes.onflow.org:9000','external_table', 'transactions_mainnet_15', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 21291692
AND 23830812
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet16.nodes.onflow.org:9000','external_table', 'transactions_mainnet_16', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 23830813
AND 27341469
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet17.nodes.onflow.org:9000','external_table', 'transactions_mainnet_17', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 27341470
AND 31735954
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet18.nodes.onflow.org:9000','external_table', 'transactions_mainnet_18', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 31735955
AND 35858810
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet19.nodes.onflow.org:9000','external_table', 'transactions_mainnet_19', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 35858811
AND 40171633
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet20.nodes.onflow.org:9000','external_table', 'transactions_mainnet_20', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 40171634
AND 44950206
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet21.nodes.onflow.org:9000','external_table', 'transactions_mainnet_21', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 44950207
AND 47169686
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet22.nodes.onflow.org:9000','external_table', 'transactions_mainnet_22', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 47169687
AND 55114466
ORDER BY
block_height ASC

View File

@ -3,8 +3,7 @@
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc(object_construct('sql_source', '{{this.identifier}}','node_url', '{{ var('node_url', Null) }}','external_table', 'blocks', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
),
tags = ['streamline_history']
)
) }}
WITH blocks AS (

View File

@ -3,8 +3,7 @@
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc(object_construct('sql_source', '{{this.identifier}}','node_url','{{ var('node_url', Null) }}','external_table', 'collections', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
),
tags = ['streamline_history']
)
) }}
WITH blocks AS (

View File

@ -3,8 +3,7 @@
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc(object_construct('sql_source', '{{this.identifier}}', 'node_url', '{{ var('node_url', Null) }}', 'external_table', 'transaction_results', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','30000')}}, 'worker_batch_size', {{var('worker_batch_size','3000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
),
tags = ['streamline_history']
)
) }}
WITH blocks AS (

View File

@ -3,8 +3,7 @@
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc(object_construct('sql_source', '{{this.identifier}}', 'node_url', '{{ var('node_url', Null) }}', 'external_table', 'transactions', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','30000')}}, 'worker_batch_size', {{var('worker_batch_size','3000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
),
tags = ['streamline_history']
)
) }}
WITH blocks AS (

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.candidate7.nodes.onflow.org:9000','external_table', 'transaction_results_candidate_07', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transaction_results") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction_result',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 4132133
AND 4972986
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.candidate8.nodes.onflow.org:9000','external_table', 'transaction_results_candidate_08', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transaction_results") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction_result',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 4972987
AND 6483245
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.candidate9.nodes.onflow.org:9000','external_table', 'transaction_results_candidate_09', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transaction_results") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction_result',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 6483246
AND 7601062
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet1.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_01', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transaction_results") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction_result',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 7601063
AND 8742958
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet2.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_02', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transaction_results") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction_result',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 8742959
AND 9737132
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet3.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_03', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transaction_results") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction_result',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 9737133
AND 9992019
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet4.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_04', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transaction_results") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction_result',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 9992020
AND 12020336
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet5.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_05', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transaction_results") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction_result',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 12020337
AND 12609236
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet6.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_06', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transaction_results") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction_result',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 12609237
AND 13404173
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet7.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_07', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transaction_results") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction_result',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 13404174
AND 13950741
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet8.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_08', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transaction_results") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction_result',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 13950742
AND 14892103
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet9.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_09', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transaction_results") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction_result',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 14892104
AND 15791890
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet10.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_10', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transaction_results") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction_result',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 15791891
AND 16755601
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet11.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_11', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transaction_results") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction_result',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 16755602
AND 17544522
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet12.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_12', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transaction_results") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction_result',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 17544523
AND 18587477
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet13.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_13', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transaction_results") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction_result',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 18587478
AND 19050752
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet14.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_14', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transaction_results") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction_result',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 19050753
AND 21291691
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet15.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_15', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transaction_results") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction_result',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 21291692
AND 23830812
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet16.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_16', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transaction_results") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction_result',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 23830813
AND 27341469
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet17.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_17', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transaction_results") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction_result',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 27341470
AND 31735954
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet18.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_18', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transaction_results") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction_result',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 31735955
AND 35858810
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet19.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_19', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transaction_results") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction_result',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 35858811
AND 40171633
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet20.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_20', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transaction_results") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction_result',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 40171634
AND 44950206
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet21.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_21', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transaction_results") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction_result',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 44950207
AND 47169686
ORDER BY
block_height ASC

View File

@ -0,0 +1,45 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet22.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_22', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number AS block_height
FROM
{{ ref("streamline__complete_get_transaction_results") }}
),
tx AS (
SELECT
block_number AS block_height,
DATA
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks
ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction_result',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value :: STRING)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(DATA) :transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 47169687
AND 55114466
ORDER BY
block_height ASC

View File

@ -0,0 +1,43 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.candidate7.nodes.onflow.org:9000','external_table', 'transactions_candidate_07', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number as block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number as block_height,
data
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value::string)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(data):transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 4132133
AND 4972986
ORDER BY
block_height ASC

View File

@ -0,0 +1,43 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.candidate8.nodes.onflow.org:9000','external_table', 'transactions_candidate_08', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number as block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number as block_height,
data
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value::string)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(data):transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 4972987
AND 6483245
ORDER BY
block_height ASC

View File

@ -0,0 +1,43 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.candidate9.nodes.onflow.org:9000','external_table', 'transactions_candidate_09', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number as block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number as block_height,
data
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value::string)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(data):transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 6483246
AND 7601062
ORDER BY
block_height ASC

View File

@ -0,0 +1,43 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet1.nodes.onflow.org:9000','external_table', 'transactions_mainnet_01', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number as block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number as block_height,
data
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value::string)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(data):transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 7601063
AND 8742958
ORDER BY
block_height ASC

View File

@ -0,0 +1,43 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet2.nodes.onflow.org:9000','external_table', 'transactions_mainnet_02', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number as block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number as block_height,
data
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value::string)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(data):transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 8742959
AND 9737132
ORDER BY
block_height ASC

View File

@ -0,0 +1,43 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet3.nodes.onflow.org:9000','external_table', 'transactions_mainnet_03', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number as block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number as block_height,
data
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value::string)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(data):transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 9737133
AND 9992019
ORDER BY
block_height ASC

View File

@ -0,0 +1,43 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet4.nodes.onflow.org:9000','external_table', 'transactions_mainnet_04', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number as block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number as block_height,
data
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value::string)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(data):transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 9992020
AND 12020336
ORDER BY
block_height ASC

View File

@ -0,0 +1,43 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet5.nodes.onflow.org:9000','external_table', 'transactions_mainnet_05', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number as block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number as block_height,
data
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value::string)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(data):transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 12020337
AND 12609236
ORDER BY
block_height ASC

View File

@ -0,0 +1,43 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet6.nodes.onflow.org:9000','external_table', 'transactions_mainnet_06', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number as block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number as block_height,
data
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value::string)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(data):transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 12609237
AND 13404173
ORDER BY
block_height ASC

View File

@ -0,0 +1,43 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet7.nodes.onflow.org:9000','external_table', 'transactions_mainnet_07', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number as block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number as block_height,
data
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value::string)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(data):transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 13404174
AND 13950741
ORDER BY
block_height ASC

View File

@ -0,0 +1,43 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet8.nodes.onflow.org:9000','external_table', 'transactions_mainnet_08', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number as block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number as block_height,
data
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value::string)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(data):transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 13950742
AND 14892103
ORDER BY
block_height ASC

View File

@ -0,0 +1,43 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet9.nodes.onflow.org:9000','external_table', 'transactions_mainnet_09', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number as block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number as block_height,
data
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value::string)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(data):transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 14892104
AND 15791890
ORDER BY
block_height ASC

View File

@ -0,0 +1,43 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet10.nodes.onflow.org:9000','external_table', 'transactions_mainnet_10', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number as block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number as block_height,
data
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value::string)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(data):transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 15791891
AND 16755601
ORDER BY
block_height ASC

View File

@ -0,0 +1,43 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet11.nodes.onflow.org:9000','external_table', 'transactions_mainnet_11', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number as block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number as block_height,
data
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value::string)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(data):transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 16755602
AND 17544522
ORDER BY
block_height ASC

View File

@ -0,0 +1,43 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet12.nodes.onflow.org:9000','external_table', 'transactions_mainnet_12', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number as block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number as block_height,
data
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value::string)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(data):transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 17544523
AND 18587477
ORDER BY
block_height ASC

View File

@ -0,0 +1,43 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc_us_east_2(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet13.nodes.onflow.org:9000','external_table', 'transactions_mainnet_13', 'sql_limit', {{var('sql_limit','500000')}}, 'producer_batch_size', {{var('producer_batch_size','10000')}}, 'worker_batch_size', {{var('worker_batch_size','1000')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
)
) }}
WITH blocks AS (
SELECT
block_height
FROM
{{ ref("streamline__blocks") }}
EXCEPT
SELECT
block_number as block_height
FROM
{{ ref("streamline__complete_get_transactions") }}
),
tx AS (
SELECT
block_number as block_height,
data
FROM
{{ ref('streamline__complete_get_collections') }}
JOIN blocks ON blocks.block_height = block_number
)
SELECT
OBJECT_CONSTRUCT(
'grpc', 'proto3',
'method', 'get_transaction',
'block_height', block_height::INTEGER,
'transaction_id', transaction_id.value::string,
'method_params', OBJECT_CONSTRUCT('id', transaction_id.value::string)
) AS request
FROM
tx,
LATERAL FLATTEN(input => TRY_PARSE_JSON(data):transaction_ids) AS transaction_id
WHERE
block_height BETWEEN 18587478
AND 19050752
ORDER BY
block_height ASC

Some files were not shown because too many files have changed in this diff Show More