flip/axelar-models
1
0
Fork 0
mirror of https://github.com/FlipsideCrypto/axelar-models.git synced 2026-02-06 13:41:55 +00:00
Code Issues Actions 5 Packages Projects Releases Wiki Activity

.sql

Browse Source
This commit is contained in:
Eric Laurello 2023-11-10 13:46:09 -05:00
parent d35a475ac3
commit 9e0a3d3b8b
36 changed files with 269 additions and 40 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
dbt_project.yml
View File

@ -30,6 +30,7 @@ models:
+persist_docs:
relation: true
columns: true
+on_schema_change: "append_new_columns"
tests:
+store_failures: true # all tests

8
models/silver/_observability/silver_observability__blocks_completeness.sql
View File

@ -116,7 +116,13 @@ SELECT
)
END
) AS test_failure_details,
SYSDATE() AS test_timestamp
SYSDATE() AS test_timestamp,
{{ dbt_utils.generate_surrogate_key(
['SYSDATE()']
) }} AS blocks_completeness_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
block_gen A
LEFT JOIN source b

8
models/silver/_observability/silver_observability__transactions_completeness.sql
View File

@ -250,7 +250,13 @@ SELECT
ORDER BY
A.block_id
) AS test_failure_details,
SYSDATE() AS test_timestamp
SYSDATE() AS test_timestamp,
{{ dbt_utils.generate_surrogate_key(
['SYSDATE()']
) }} AS transactions_completeness_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
bronze_api A
LEFT JOIN bronze_count b

9
models/silver/core/silver__blockchain.sql
View File

@ -2,6 +2,7 @@
materialized = 'incremental',
unique_key = "block_id",
incremental_strategy = 'merge',
merge_exclude_columns = ["inserted_timestamp"],
cluster_by = ['block_timestamp::DATE'],
) }}
@ -59,7 +60,13 @@ SELECT
block_header,
block_id AS block_id_object,
num_txs,
_inserted_timestamp
{{ dbt_utils.generate_surrogate_key(
['height']
) }} AS blockchain_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
_inserted_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
fin qualify(ROW_NUMBER() over(PARTITION BY height
ORDER BY

10
models/silver/core/silver__blocks.sql
View File

@ -37,12 +37,18 @@ SELECT
DATA :result :block :header,
DATA :block :header
) AS header,
_inserted_timestamp,
concat_ws(
'-',
chain_id,
block_id
) AS _unique_key
) AS _unique_key,
{{ dbt_utils.generate_surrogate_key(
['chain_id','block_id']
) }} AS blocks_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
_inserted_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
{{ ref('bronze__blocks') }}
WHERE

8
models/silver/core/silver__daily_balances.sql
View File

@ -172,6 +172,12 @@ SELECT
balance_type
ORDER BY
DATE ASC rows unbounded preceding
) AS balance
) AS balance,
{{ dbt_utils.generate_surrogate_key(
['date','address','balance_type', 'currency']
) }} AS daily_balances_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
balance_temp

8
models/silver/core/silver__link_events.sql
View File

@ -72,7 +72,13 @@ SELECT
destination_chain,
destination_address,
asset,
j,
{{ dbt_utils.generate_surrogate_key(
['tx_id']
) }} AS link_events_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
_inserted_timestamp,
j
'{{ invocation_id }}' AS _invocation_id
FROM
fin

10
models/silver/core/silver__msg_attributes.sql
View File

@ -27,7 +27,13 @@ SELECT
msg_index,
attribute_index
) AS _unique_key,
_inserted_timestamp
{{ dbt_utils.generate_surrogate_key(
['tx_id','msg_index','attribute_index']
) }} AS msg_attributes_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
_inserted_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
{{ ref('silver__msgs') }} A,
LATERAL FLATTEN(
@ -39,7 +45,7 @@ FROM
WHERE
_inserted_timestamp :: DATE >= (
SELECT
MAX(_inserted_timestamp) :: DATE - 2
MAX(_inserted_timestamp) :: DATE - 2
FROM
{{ this }}
)

8
models/silver/core/silver__msgs.sql
View File

@ -118,7 +118,13 @@ FINAL AS (
A.tx_id,
A.msg_index
) AS _unique_key,
_inserted_timestamp
{{ dbt_utils.generate_surrogate_key(
['a.tx_id','a.msg_index']
) }} AS msgs_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
_inserted_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
base A
LEFT JOIN GROUPING b

8
models/silver/core/silver__staked_balances.sql
View File

@ -59,6 +59,12 @@ SELECT
ORDER BY
block_timestamp ASC rows unbounded preceding
) AS balance,
_inserted_timestamp
{{ dbt_utils.generate_surrogate_key(
['block_id','address','currency']
) }} AS staked_balances_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
_inserted_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
all_staked

8
models/silver/core/silver__transactions.sql
View File

@ -51,7 +51,13 @@ SELECT
tx_code,
msgs,
tx_log :: STRING AS tx_log,
b._inserted_timestamp
{{ dbt_utils.generate_surrogate_key(
['tx_id']
) }} AS transactions_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
b._inserted_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
base_table b
LEFT OUTER JOIN {{ ref('silver__blocks') }}

9
models/silver/core/silver__transfer_details.sql
View File

@ -2,6 +2,7 @@
materialized = 'incremental',
unique_key = ["tx_id","msg_group","msg_sub_group"],
incremental_strategy = 'merge',
merge_exclude_columns = ["inserted_timestamp"],
cluster_by = 'block_timestamp::DATE'
) }}
@ -202,6 +203,12 @@ SELECT
tokenAddress AS token_address,
txID AS txid,
confHeight AS conf_height,
_inserted_timestamp
{{ dbt_utils.generate_surrogate_key(
['tx_id','msg_group','msg_sub_group']
) }} AS transfer_details_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
_inserted_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
fin

9
models/silver/core/silver__transfers.sql
View File

@ -2,6 +2,7 @@
materialized = 'incremental',
unique_key = ['tx_id','msg_index'],
incremental_strategy = 'merge',
merge_exclude_columns = ["inserted_timestamp"],
cluster_by = ['block_timestamp::DATE']
) }}
@ -146,7 +147,13 @@ SELECT
A.msg_index,
b.destination_address AS foreign_address,
b.destination_chain AS foreign_chain,
A._inserted_timestamp
{{ dbt_utils.generate_surrogate_key(
['a.tx_id','a.msg_index']
) }} AS transfers_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
A._inserted_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
fin A
LEFT JOIN decimals d

8
models/silver/core/silver__transfers_ExecutePendingTransfers.sql
View File

@ -189,8 +189,14 @@ SELECT
transfer_id,
snd.deposit_address AS foreign_address,
snd.source_chain AS foreign_chain,
_unique_key,
{{ dbt_utils.generate_surrogate_key(
['tx_id','msg_index']
) }} AS transfer_executependingtransfers_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
_inserted_timestamp,
_unique_key
'{{ invocation_id }}' AS _invocation_id
FROM
txs_final i
LEFT JOIN decimals d

9
models/silver/core/silver__transfers_ibc.sql
View File

@ -2,6 +2,7 @@
materialized = 'incremental',
unique_key = ['tx_id','msg_index'],
incremental_strategy = 'merge',
merge_exclude_columns = ["inserted_timestamp"],
cluster_by = ['block_timestamp::DATE']
) }}
@ -290,7 +291,13 @@ SELECT
currency,
b.destination_address AS foreign_address,
b.destination_chain AS foreign_chain,
i._inserted_timestamp
{{ dbt_utils.generate_surrogate_key(
['i.tx_id','i.msg_index']
) }} AS transfers_ibc_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
_inserted_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
new_fin i
LEFT JOIN decimals d

9
models/silver/core/silver__transfers_ibc_packets.sql
View File

@ -2,6 +2,7 @@
materialized = 'incremental',
unique_key = ['tx_id','msg_index'],
incremental_strategy = 'merge',
merge_exclude_columns = ["inserted_timestamp"],
cluster_by = ['block_timestamp::DATE']
) }}
@ -87,6 +88,12 @@ SELECT
packet_sequence,
packet_src_channel,
packet_dst_channel,
_inserted_timestamp
{{ dbt_utils.generate_surrogate_key(
['tx_id','msg_index']
) }} AS transfers_ibc_packets_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
_inserted_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
all_data

9
models/silver/defi/satellite/silver__satellite_arbitrum.sql
View File

@ -2,6 +2,7 @@
materialized = 'incremental',
unique_key = "tx_hash",
incremental_strategy = 'merge',
merge_exclude_columns = ["inserted_timestamp"],
cluster_by = 'block_timestamp::DATE',
) }}
@ -117,7 +118,13 @@ SELECT
#}
tokenaddress AS token_address,
raw_amount,
depositaddress AS deposit_address
depositaddress AS deposit_address,
{{ dbt_utils.generate_surrogate_key(
['tx_hash']
) }} AS satellite_arbitrum_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
links
JOIN labeled_transfer_amount USING (depositAddress)

9
models/silver/defi/satellite/silver__satellite_avalanche.sql
View File

@ -2,6 +2,7 @@
materialized = 'incremental',
unique_key = "tx_hash",
incremental_strategy = 'merge',
merge_exclude_columns = ["inserted_timestamp"],
cluster_by = 'block_timestamp::DATE',
) }}
@ -117,7 +118,13 @@ SELECT
#}
tokenaddress AS token_address,
raw_amount,
depositaddress AS deposit_address
depositaddress AS deposit_address,
{{ dbt_utils.generate_surrogate_key(
['tx_hash']
) }} AS satellite_avalanche_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
links
JOIN labeled_transfer_amount USING (depositAddress)

9
models/silver/defi/satellite/silver__satellite_axelar.sql
View File

@ -2,6 +2,7 @@
materialized = 'incremental',
unique_key = "_unique_key",
incremental_strategy = 'merge',
merge_exclude_columns = ["inserted_timestamp"],
cluster_by = 'block_timestamp::DATE',
) }}
@ -86,7 +87,13 @@ SELECT
'-',
A.tx_hash,
A.msg_index
) AS _unique_key
) AS _unique_key,
{{ dbt_utils.generate_surrogate_key(
['tx_hash']
) }} AS satellite_axelar_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
xfer_base A
LEFT JOIN transfer_det b

9
models/silver/defi/satellite/silver__satellite_bsc.sql
View File

@ -2,6 +2,7 @@
materialized = 'incremental',
unique_key = "tx_hash",
incremental_strategy = 'merge',
merge_exclude_columns = ["inserted_timestamp"],
cluster_by = 'block_timestamp::DATE',
) }}
@ -117,7 +118,13 @@ SELECT
#}
tokenaddress AS token_address,
raw_amount,
depositaddress AS deposit_address
depositaddress AS deposit_address,
{{ dbt_utils.generate_surrogate_key(
['tx_hash']
) }} AS satellite_bsc_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
links
JOIN labeled_transfer_amount USING (depositAddress)

9
models/silver/defi/satellite/silver__satellite_ethereum.sql
View File

@ -2,6 +2,7 @@
materialized = 'incremental',
unique_key = "tx_hash",
incremental_strategy = 'merge',
merge_exclude_columns = ["inserted_timestamp"],
cluster_by = 'block_timestamp::DATE',
) }}
@ -117,7 +118,13 @@ SELECT
#}
tokenaddress AS token_address,
raw_amount,
depositaddress AS deposit_address
depositaddress AS deposit_address,
{{ dbt_utils.generate_surrogate_key(
['tx_hash']
) }} AS satellite_ethereum_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
links
JOIN labeled_transfer_amount USING (depositAddress)

9
models/silver/defi/satellite/silver__satellite_polygon.sql
View File

@ -2,6 +2,7 @@
materialized = 'incremental',
unique_key = "tx_hash",
incremental_strategy = 'merge',
merge_exclude_columns = ["inserted_timestamp"],
cluster_by = 'block_timestamp::DATE',
) }}
@ -117,7 +118,13 @@ SELECT
#}
tokenaddress AS token_address,
raw_amount,
depositaddress AS deposit_address
depositaddress AS deposit_address,
{{ dbt_utils.generate_surrogate_key(
['tx_hash']
) }} AS satellite_polygon_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
links
JOIN labeled_transfer_amount USING (depositAddress)

11
models/silver/defi/silver__staking.sql
View File

@ -2,6 +2,7 @@
materialized = 'incremental',
unique_key = "_unique_key",
incremental_strategy = 'merge',
merge_exclude_columns = ["inserted_timestamp"],
cluster_by = ['block_timestamp::DATE']
) }}
@ -284,7 +285,6 @@ SELECT
A.redelegate_source_validator_address,
A.completion_time :: datetime completion_time,
A.msg_group,
A._inserted_timestamp,
concat_ws(
'-',
A.tx_id,
@ -293,7 +293,14 @@ SELECT
currency,
delegator_address,
validator_address
) AS _unique_key
) AS _unique_key,
{{ dbt_utils.generate_surrogate_key(
['A.tx_id','A.msg_group','A.action','currency','A.delegator_address','A.validator_address']
) }} AS staking_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
A._inserted_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
prefinal A
JOIN LATERAL SPLIT_TO_TABLE(

14
models/silver/defi/silver__staking_rewards.sql
View File

@ -2,6 +2,7 @@
materialized = 'incremental',
unique_key = "_unique_key",
incremental_strategy = 'merge',
merge_exclude_columns = ["inserted_timestamp"],
cluster_by = ['block_timestamp::DATE']
) }}
@ -406,7 +407,6 @@ SELECT
ELSE 'uaxl'
END AS currency,
A.validator_address,
b._inserted_timestamp,
concat_ws(
'-',
A.tx_id,
@ -415,7 +415,14 @@ SELECT
currency,
A.delegator_address,
A.validator_address
) AS _unique_key
) AS _unique_key,
{{ dbt_utils.generate_surrogate_key(
['A.tx_id','A.msg_group','A.action','currency','A.delegator_address','A.validator_address']
) }} AS staking_rewards_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
b._inserted_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
combo_all A
JOIN LATERAL SPLIT_TO_TABLE(
@ -437,4 +444,5 @@ GROUP BY
A.delegator_address,
currency,
A.validator_address,
b._inserted_timestamp
b._inserted_timestamp,
staking_rewards_id

9
models/silver/defi/silver__validator_commission.sql
View File

@ -2,6 +2,7 @@
materialized = 'incremental',
unique_key = "tx_id",
incremental_strategy = 'merge',
merge_exclude_columns = ["inserted_timestamp"],
cluster_by = ['block_timestamp::DATE']
) }}
@ -117,7 +118,13 @@ SELECT
'uaxl' AS currency,
A.validator_address_operator,
A.validator_address_reward,
b._inserted_timestamp
{{ dbt_utils.generate_surrogate_key(
['a.tx_id']
) }} AS staking_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
b._inserted_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
combo A
JOIN block_tx_inserted b

8
models/silver/defi/silver__validators.sql
View File

@ -27,6 +27,12 @@ SELECT
address,
creator,
blockchain
) AS unique_key
) AS unique_key,
{{ dbt_utils.generate_surrogate_key(
['address','creator','blockchain']
) }} AS validators_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
{{ ref('bronze_api__get_validator_metadata') }}

8
models/silver/defi/squid/silver__squid_arbitrum.sql
View File

@ -2,6 +2,7 @@
materialized = 'incremental',
unique_key = "tx_hash",
incremental_strategy = 'merge',
merge_exclude_columns = ["inserted_timestamp"],
cluster_by = 'block_timestamp::DATE',
) }}
@ -191,6 +192,11 @@ nonevm_fix_data AS (
) AS token_symbol,
LOWER(REGEXP_REPLACE(destination_chain, '[^a-zA-Z0-9]+')) AS destination_chain,
LOWER(receiver) AS receiver,
_inserted_timestamp
{{ dbt_utils.generate_surrogate_key(
['tx_hash']
) }} AS squid_arbitrum_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
arb_result

8
models/silver/defi/squid/silver__squid_avalanche.sql
View File

@ -2,6 +2,7 @@
materialized = 'incremental',
unique_key = "tx_hash",
incremental_strategy = 'merge',
merge_exclude_columns = ["inserted_timestamp"],
cluster_by = 'block_timestamp::DATE',
) }}
@ -194,6 +195,11 @@ nonevm_fix_data AS (
ELSE LOWER(REGEXP_REPLACE(destination_chain, '[^a-zA-Z0-9]+'))
END AS destination_chain,
LOWER(receiver) AS receiver,
_inserted_timestamp
{{ dbt_utils.generate_surrogate_key(
['tx_hash']
) }} AS squid_avalanche_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
arb_result A

8
models/silver/defi/squid/silver__squid_base.sql
View File

@ -2,6 +2,7 @@
materialized = 'incremental',
unique_key = "tx_hash",
incremental_strategy = 'merge',
merge_exclude_columns = ["inserted_timestamp"],
cluster_by = 'block_timestamp::DATE',
) }}
@ -191,6 +192,11 @@ nonevm_fix_data AS (
) AS token_symbol,
LOWER(REGEXP_REPLACE(destination_chain, '[^a-zA-Z0-9]+')) AS destination_chain,
LOWER(receiver) AS receiver,
_inserted_timestamp
{{ dbt_utils.generate_surrogate_key(
['tx_hash']
) }} AS squid_base_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
base_result

8
models/silver/defi/squid/silver__squid_bsc.sql
View File

@ -2,6 +2,7 @@
materialized = 'incremental',
unique_key = "tx_hash",
incremental_strategy = 'merge',
merge_exclude_columns = ["inserted_timestamp"],
cluster_by = 'block_timestamp::DATE',
) }}
@ -195,6 +196,11 @@ nonevm_fix_data AS (
) AS token_symbol,
LOWER(REGEXP_REPLACE(destination_chain, '[^a-zA-Z0-9]+')) AS destination_chain,
LOWER(receiver) AS receiver,
_inserted_timestamp
{{ dbt_utils.generate_surrogate_key(
['tx_hash']
) }} AS squid_bsc_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
arb_result A

8
models/silver/defi/squid/silver__squid_ethereum.sql
View File

@ -2,6 +2,7 @@
materialized = 'incremental',
unique_key = "tx_hash",
incremental_strategy = 'merge',
merge_exclude_columns = ["inserted_timestamp"],
cluster_by = 'block_timestamp::DATE',
) }}
@ -111,7 +112,12 @@ SELECT
),
sender
) AS receiver,
_inserted_timestamp
{{ dbt_utils.generate_surrogate_key(
['a.tx_hash']
) }} AS squid_ethereum_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
dec_logs_base A
JOIN squid_to_gateway b

8
models/silver/defi/squid/silver__squid_optimism.sql
View File

@ -2,6 +2,7 @@
materialized = 'incremental',
unique_key = "tx_hash",
incremental_strategy = 'merge',
merge_exclude_columns = ["inserted_timestamp"],
cluster_by = 'block_timestamp::DATE',
) }}
@ -191,6 +192,11 @@ nonevm_fix_data AS (
) AS token_symbol,
LOWER(REGEXP_REPLACE(destination_chain, '[^a-zA-Z0-9]+')) AS destination_chain,
LOWER(receiver) AS receiver,
_inserted_timestamp
{{ dbt_utils.generate_surrogate_key(
['tx_hash']
) }} AS squid_optimism_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
op_result

8
models/silver/defi/squid/silver__squid_polygon.sql
View File

@ -2,6 +2,7 @@
materialized = 'incremental',
unique_key = "tx_hash",
incremental_strategy = 'merge',
merge_exclude_columns = ["inserted_timestamp"],
cluster_by = 'block_timestamp::DATE',
) }}
@ -195,6 +196,11 @@ nonevm_fix_data AS (
) AS token_symbol,
LOWER(REGEXP_REPLACE(destination_chain, '[^a-zA-Z0-9]+')) AS destination_chain,
LOWER(receiver) AS receiver,
_inserted_timestamp
{{ dbt_utils.generate_surrogate_key(
['tx_hash']
) }} AS squid_polygon_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
arb_result A

9
models/silver/gov/silver__governance_proposal_deposits.sql
View File

@ -2,6 +2,7 @@
materialized = 'incremental',
unique_key = "tx_id",
incremental_strategy = 'merge',
merge_exclude_columns = ["inserted_timestamp"],
cluster_by = ['block_timestamp::DATE']
) }}
@ -104,7 +105,13 @@ SELECT
p.proposal_id :: NUMBER AS proposal_id,
v.amount :: NUMBER AS amount,
v.currency,
_inserted_timestamp
{{ dbt_utils.generate_surrogate_key(
['p.tx_id']
) }} AS governance_proposal_deposits_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
_inserted_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
deposit_value v
INNER JOIN proposal_ids p

9
models/silver/gov/silver__governance_submit_proposal.sql
View File

@ -2,6 +2,7 @@
materialized = 'incremental',
unique_key = "tx_id",
incremental_strategy = 'merge',
merge_exclude_columns = ["inserted_timestamp"],
cluster_by = ['block_timestamp::DATE']
) }}
@ -86,7 +87,13 @@ SELECT
proposer,
p.proposal_id :: NUMBER AS proposal_id,
y.proposal_type,
_inserted_timestamp
{{ dbt_utils.generate_surrogate_key(
['p.tx_id']
) }} AS governance_submit_proposal_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
_inserted_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
proposal_ids p
INNER JOIN proposal_type y

9
models/silver/gov/silver__governance_votes.sql
View File

@ -2,6 +2,7 @@
materialized = 'incremental',
unique_key = ['tx_id','proposal_id','voter'],
incremental_strategy = 'merge',
merge_exclude_columns = ["inserted_timestamp"],
cluster_by = ['block_timestamp::DATE']
) }}
@ -93,7 +94,13 @@ SELECT
ELSE A.vote_option :: INT
END AS vote_option,
A.vote_weight,
A._inserted_timestamp
{{ dbt_utils.generate_surrogate_key(
['a.tx_id','a.proposal_id','b.voter']
) }} AS governance_votes_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
A._inserted_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
fin A
LEFT JOIN (