Skip to content

Commit

Permalink
fix log unique test - update for distinct traces
Browse files Browse the repository at this point in the history
  • Loading branch information
SeblyAnalytics committed Jun 20, 2024
1 parent 088edd5 commit cfbb451
Show file tree
Hide file tree
Showing 32 changed files with 16 additions and 32 deletions.
2 changes: 1 addition & 1 deletion models/pyth/arbitrum/pyth_arbitrum_price_feed_logs.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
unique_key = ['block_number', 'chain', 'tx_hash', 'index'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["arbitrum"]\',
"project",
Expand Down
1 change: 0 additions & 1 deletion models/pyth/arbitrum/pyth_arbitrum_transactions.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["arbitrum"]\',
"project",
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
unique_key = ['block_number', 'chain', 'tx_hash', 'index'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["avalanche_c"]\',
"project",
Expand Down
1 change: 0 additions & 1 deletion models/pyth/avalanche_c/pyth_avalanche_c_transactions.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["avalanche_c"]\',
"project",
Expand Down
2 changes: 1 addition & 1 deletion models/pyth/base/pyth_base_price_feed_logs.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
unique_key = ['block_number', 'chain', 'tx_hash', 'index'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["base"]\',
"project",
Expand Down
1 change: 0 additions & 1 deletion models/pyth/base/pyth_base_transactions.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["base"]\',
"project",
Expand Down
2 changes: 1 addition & 1 deletion models/pyth/blast/pyth_blast_price_feed_logs.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
unique_key = ['block_number', 'chain', 'tx_hash', 'index'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["blast"]\',
"project",
Expand Down
1 change: 0 additions & 1 deletion models/pyth/blast/pyth_blast_transactions.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["blast"]\',
"project",
Expand Down
2 changes: 1 addition & 1 deletion models/pyth/bnb/pyth_bnb_price_feed_logs.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
unique_key = ['block_number', 'chain', 'tx_hash', 'index'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["bnb"]\',
"project",
Expand Down
1 change: 0 additions & 1 deletion models/pyth/bnb/pyth_bnb_transactions.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["bnb"]\',
"project",
Expand Down
2 changes: 1 addition & 1 deletion models/pyth/celo/pyth_celo_price_feed_logs.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
unique_key = ['block_number', 'chain', 'tx_hash', 'index'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["celo"]\',
"project",
Expand Down
1 change: 0 additions & 1 deletion models/pyth/celo/pyth_celo_transactions.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["celo"]\',
"project",
Expand Down
2 changes: 1 addition & 1 deletion models/pyth/ethereum/pyth_ethereum_price_feed_logs.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
unique_key = ['block_number', 'chain', 'tx_hash', 'index'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["ethereum"]\',
"project",
Expand Down
1 change: 0 additions & 1 deletion models/pyth/ethereum/pyth_ethereum_transactions.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["ethereum"]\',
"project",
Expand Down
2 changes: 1 addition & 1 deletion models/pyth/fantom/pyth_fantom_price_feed_logs.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
unique_key = ['block_number', 'chain', 'tx_hash', 'index'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["fantom"]\',
"project",
Expand Down
1 change: 0 additions & 1 deletion models/pyth/fantom/pyth_fantom_transactions.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["fantom"]\',
"project",
Expand Down
2 changes: 1 addition & 1 deletion models/pyth/gnosis/pyth_gnosis_price_feed_logs.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
unique_key = ['block_number', 'chain', 'tx_hash', 'index'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["gnosis"]\',
"project",
Expand Down
1 change: 0 additions & 1 deletion models/pyth/gnosis/pyth_gnosis_transactions.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["gnosis"]\',
"project",
Expand Down
2 changes: 1 addition & 1 deletion models/pyth/linea/pyth_linea_price_feed_logs.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
unique_key = ['block_number', 'chain', 'tx_hash', 'index'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["linea"]\',
"project",
Expand Down
1 change: 0 additions & 1 deletion models/pyth/linea/pyth_linea_transactions.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["linea"]\',
"project",
Expand Down
2 changes: 1 addition & 1 deletion models/pyth/mantle/pyth_mantle_price_feed_logs.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
unique_key = ['block_number', 'chain', 'tx_hash', 'index'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["mantle"]\',
"project",
Expand Down
1 change: 0 additions & 1 deletion models/pyth/mantle/pyth_mantle_transactions.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["mantle"]\',
"project",
Expand Down
2 changes: 1 addition & 1 deletion models/pyth/optimism/pyth_optimism_price_feed_logs.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
unique_key = ['block_number', 'chain', 'tx_hash', 'index'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["optimism"]\',
"project",
Expand Down
1 change: 0 additions & 1 deletion models/pyth/optimism/pyth_optimism_transactions.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["optimism"]\',
"project",
Expand Down
2 changes: 1 addition & 1 deletion models/pyth/polygon/pyth_polygon_price_feed_logs.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
unique_key = ['block_number', 'chain', 'tx_hash', 'index'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["polygon"]\',
"project",
Expand Down
1 change: 0 additions & 1 deletion models/pyth/polygon/pyth_polygon_transactions.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["polygon"]\',
"project",
Expand Down
2 changes: 1 addition & 1 deletion models/pyth/scroll/pyth_scroll_price_feed_logs.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
unique_key = ['block_number', 'chain', 'tx_hash', 'index'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["scroll"]\',
"project",
Expand Down
1 change: 0 additions & 1 deletion models/pyth/scroll/pyth_scroll_transactions.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["scroll"]\',
"project",
Expand Down
2 changes: 1 addition & 1 deletion models/pyth/zkevm/pyth_zkevm_price_feed_logs.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
unique_key = ['block_number', 'chain', 'tx_hash', 'index'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["zkevm"]\',
"project",
Expand Down
1 change: 0 additions & 1 deletion models/pyth/zkevm/pyth_zkevm_transactions.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["zkevm"]\',
"project",
Expand Down
2 changes: 1 addition & 1 deletion models/pyth/zksync/pyth_zksync_price_feed_logs.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
unique_key = ['block_number', 'chain', 'tx_hash', 'index'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["zksync"]\',
"project",
Expand Down
1 change: 0 additions & 1 deletion models/pyth/zksync/pyth_zksync_transactions.sql
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
unique_key = ['block_time', 'chain', 'trace_address', 'trace_from'],
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
post_hook='{{ expose_spells(\'["zksync"]\',
"project",
Expand Down

0 comments on commit cfbb451

Please sign in to comment.