From e3d0d0f59d5b25f34406eacdd64628d467cad529 Mon Sep 17 00:00:00 2001 From: Eric Laurello Date: Wed, 29 May 2024 10:56:59 -0400 Subject: [PATCH] couple of small updates --- macros/streamline/api_integrations.sql | 2 +- .../silver/realtime/streamline__tx_counts_realtime.sql | 9 ++++----- 2 files changed, 5 insertions(+), 6 deletions(-) diff --git a/macros/streamline/api_integrations.sql b/macros/streamline/api_integrations.sql index 35a005b..25b9fda 100644 --- a/macros/streamline/api_integrations.sql +++ b/macros/streamline/api_integrations.sql @@ -1,7 +1,7 @@ {% macro create_aws_cosmos_api() %} {% if target.name == "prod" %} {% set sql %} - CREATE api integration IF NOT EXISTS aws_cosmos_api api_provider = aws_api_gateway api_aws_role_arn = 'arn:aws:iam::924682671219:role/cosmos-api-prod-rolesnowflakeudfsAF733095-p9k0jZbJcQpS' api_allowed_prefixes = ( + CREATE api integration IF NOT EXISTS aws_cosmos_api_prod api_provider = aws_api_gateway api_aws_role_arn = 'arn:aws:iam::924682671219:role/cosmos-api-prod-rolesnowflakeudfsAF733095-p9k0jZbJcQpS' api_allowed_prefixes = ( 'https://kpg3w2qkm4.execute-api.us-east-1.amazonaws.com/prod/' ) enabled = TRUE; {% endset %} diff --git a/models/streamline/silver/realtime/streamline__tx_counts_realtime.sql b/models/streamline/silver/realtime/streamline__tx_counts_realtime.sql index 6d9e0f3..ba05982 100644 --- a/models/streamline/silver/realtime/streamline__tx_counts_realtime.sql +++ b/models/streamline/silver/realtime/streamline__tx_counts_realtime.sql @@ -17,16 +17,15 @@ WITH blocks AS ( block_number FROM {{ ref("streamline__blocks") }} + WHERE + block_number >= 15213800 EXCEPT SELECT block_number FROM {{ ref("streamline__complete_tx_counts") }} - ORDER BY - 1 - LIMIT - 50000 -), {# retry AS ( +), +{# retry AS ( SELECT NULL AS A.block_number FROM