From e4ee9c2bc31a81d15bef376be12e9ee131d9d657 Mon Sep 17 00:00:00 2001 From: mattroamno Date: Wed, 16 Mar 2022 19:37:42 -0700 Subject: [PATCH] additions --- models/core/transfers.sql | 19 ++++++++----------- 1 file changed, 8 insertions(+), 11 deletions(-) diff --git a/models/core/transfers.sql b/models/core/transfers.sql index c1fd135..f314586 100644 --- a/models/core/transfers.sql +++ b/models/core/transfers.sql @@ -1,4 +1,3 @@ - {{ config( materialized='incremental', @@ -11,14 +10,13 @@ with txs as ( - select - * - from {{ ref('stg_txs') }} - where {{ incremental_load_filter('block_timestamp') }} AND + select + * + from {{ ref('stg_txs') }} + where {{ incremental_load_filter('block_timestamp') }} ), - -with + actions as ( select @@ -45,9 +43,8 @@ actions as ( lateral flatten( input => tx:actions ) where action_name = 'Transfer' - ) + ), -with final as ( select @@ -56,10 +53,10 @@ final as ( signer_id, reciever_id, deposit, - try_parse_json(receipt), tx_fee, Tgas_used, - status + status, + try_parse_json(receipt) as receipt from actions )