Commit Graph

340 Commits

Author SHA1 Message Date
Jack Forgash
96755a007d
AN-5236/new transfers model (#364)
* new transfers models - still a few edge cases

* fix 1 withdrawal 2 deposited edge case

* upd filter in legacy model

* core union all and view -> incremental

* rm silver so
2024-09-19 13:31:36 -06:00
Jack Forgash
24a7caf384
fix receipts model (#363) 2024-09-16 11:08:37 -06:00
Jack Forgash
2988813d42
upd tag to non-core (#362) 2024-09-13 13:21:24 -06:00
Jack Forgash
9a7151bfc1
AN-5209/Upd staking model (#358)
* Upd staking model

* drop _s suffix

* rm event_data col

* upd desc
2024-09-13 11:07:37 -06:00
Jack Forgash
ccf595e199
AN-5100/tx actors model (#361)
* tx actors model

* upd silver

* gold ez tbl

* segment out actors from tx-level participants

* Add alias

* add rn to de-duplicate join in ez

* add incremental_predicates

* final add mod ts cluster, tx_succeeded
2024-09-13 09:40:45 -06:00
Jack Forgash
14d52208aa
rm deprecated views (#359) 2024-09-11 09:09:52 -06:00
Jack Forgash
08f0bce6b4
rn block_hash to hash (#357)
* rn block_hash to hash

* upd block gap test

* unrename gap test col
2024-09-10 10:26:32 -06:00
Jack Forgash
70d0393cfa
AN-5196 coreevm final (#356)
* an-5198-upd-block-gap-test

* evm block gap test

* evm gaps tests

* blocks and txs tests

* logs tests

* add evm gap test to daily test gha

* run evm job in separate gha workflow
2024-09-09 12:02:03 -06:00
Jack Forgash
610f0174fd
swaps final merge strat d+i (#355) 2024-09-07 10:57:24 -04:00
Jack Forgash
d113f4164a
fix typo instert (#354) 2024-09-06 11:56:00 -04:00
Jack Forgash
2dccd4f5ef
Upd Package Lock, fix core_evm incr (#353)
* fix core_evm

* package lock
2024-09-06 11:50:30 -04:00
Jack Forgash
88df737fa2
AN-5203/Deploy flowEVM (#343)
* flow evm init

* flow evm testnet - blocks

* deploy dev udfs, update typo

* send block height as hex

* dev limit

* use stg external table

* some links

* add query to side doc

* upd external tbl to stg & testnet

* silver and evm txs

* testnet silver models pt1

* testnet events final, decode hash udf

* udf get evm chainhead

* upd resource list

* new udf. receipts pipeline. upd testnet model cols. expand readme

* receipts silver

* traces

* vault

* reorg to evm dir

* rm testnet, blocks lookback

* lookbacks, move qualify

* macro and align naming

* del testnet, reset namespace to gen

* silver_evm - receipts and txs

* core_evm fact_blocks & fact_transactions

* fix vault path in get blocks. Logs v1 (need sample)

* core_evm fact_logs

* CR updates

* del readme and add workflow

* upd vault path, batch size

* incr logic on modified to core_evm

* use local utils.udf, add blockNumber col to complete blocks check

* rm col

* correct _invocation_id

* upd nv csv

* incr batch limit due to late start

* add evm tag to model run
2024-09-05 20:43:33 -06:00
Jack Forgash
e37db5668f
d+i (#352) 2024-09-04 18:45:33 -06:00
Jack Forgash
eb3247ca26
last _adj (#348) 2024-08-01 10:25:11 -06:00
Jack Forgash
433e62a63c
AN-4553/deploy new defi gold views (#345)
* bridge complete model

* depr notice on ez. Tests on fact bridge. TODOs - naming convention for amount and use chain IDs??

* ez and fact bridging

* dex swaps

* fix id col name. add platform to dex

* rm adj
2024-08-01 10:22:24 -06:00
Jack Forgash
a600e38457
upd dim metadata tests (#347) 2024-07-31 11:41:57 -06:00
Jack Forgash
3e471404e5
AN-5069/expand onchain metadata mapping (#346) 2024-07-31 08:24:25 -06:00
Jack Forgash
51607b2222
add tag back (#344) 2024-07-26 13:49:04 -06:00
eric-laurello
61c60b99c1
recorded_hour (#342) 2024-07-15 14:33:45 -04:00
eric-laurello
f6b98de014
so & clsutering (#341) 2024-07-15 09:28:47 -06:00
Jack Forgash
30ce62f6a0
AN-4936/Backfill Migration Final (#335)
* del cw models

* core views

* defi views

* gov view

* nft_views

* rm ref to old cw models

* del internal cols

* nv 13-15

* nv 13-15

* nv 17-18

* nv 20

* del temp logic

* upd tests on allday metadata

* upd to warn
2024-07-01 13:27:42 -06:00
Jack Forgash
9127e6de86
AN-4852/Testnet Integration (#326)
* source, bronze, complete, rt views

* complete testnet_ dependency

* upd sources.yml

* upd models and bronze

* upd models.sql

* upd model in bronze views

* adding chainhead_testnet

* add jobs

* fix: hour

* upd api integration

* various fixes. useast2, gha workflows, bad refs, etc

* update udtf_get_base_table

---------

Co-authored-by: WHYTEWYLL <juanmiblanco1@gmail.com>
2024-06-25 12:12:51 -06:00
Jack Forgash
12bf4e2e86
AN-4799/Backfill Migration (#329)
* move models to bronze

* blocks backfill logic ez ez ez

* streamline_load models for all 4 methods

* add back a set of views for the complete models to use

* del dbt run history gha workflow

* migrate txs final to modified ts

* upd events to modified

* set default val for LOAD_BACKFILL_VERSION in project yml

* update curated model incr logic
2024-06-12 12:10:27 -06:00
Jack Forgash
f3e6d0bfab
del deprecating price models (#332) 2024-06-12 12:02:08 -06:00
Jack Forgash
ffcb6d1492
add args to core fact_transactions (#331) 2024-06-06 22:34:28 -06:00
Jack Forgash
5ecb01870e
add script field to fact transactions (#330)
* add script field

* add to yml
2024-06-06 21:20:42 -06:00
WHYTEWYLL
f9e451debd
stats authorizer replacement (#328) 2024-06-04 17:43:30 -06:00
Jack Forgash
0b10065d52
incr batches (#325) 2024-05-23 14:55:23 -06:00
Jack Forgash
48c08901b1
fix 18 (#324) 2024-05-23 12:43:06 -06:00
WHYTEWYLL
f9be7412e6
qualify (#319)
* qualify

* data value

* moving it to flatten event

---------

Co-authored-by: forgash_ <jmfxyz@pm.me>
2024-05-06 09:22:53 -07:00
WHYTEWYLL
a0e441d668
deprecation and new view (#318)
* deprecation and new view

* reorg

* is_deprecated

* deprecated

* upd dbt model tag

---------

Co-authored-by: forgash_ <jmfxyz@pm.me>
2024-05-01 13:49:33 -06:00
WHYTEWYLL
2d85fe3e92
reducing batch size (#282) 2024-05-01 10:58:23 -07:00
Jack Forgash
894788f9b8
AA-4660 / dex swaps upd (#314)
* new swap model

* comment todos

* swaps aggregator model

* swap aggregator parsing

* upd requested fixes

* add date coalesce to ez view

* swaps agg yml

* platform doc
2024-04-22 09:59:21 -06:00
Jack Forgash
0537a64dc0
nv16 to 3mm (#310) 2024-03-21 13:30:11 -06:00
Jack Forgash
5fdadad200
19 big incr (#309) 2024-03-20 13:55:10 -06:00
Jack Forgash
cc8dc32125
Adj backfill - 16,18,19 smaller batches (#308)
* 16 smaller batches, larger backlog

* 18/19 smaller batches, larger backlog
2024-03-20 09:17:49 -06:00
Jack Forgash
575443c9aa
Adj backfill 7 - incr 16, 18, 19 (#307)
* double 16 sql limit, 33% incr on batch

* double 18/19 sql limit, ~33% incr on batch
2024-03-19 15:24:06 -06:00
Jack Forgash
8506282b5d
txres 16, 18. txs 18,19 (#306) 2024-03-19 09:20:59 -06:00
Jack Forgash
68754c046e
decr nv 19 (#305) 2024-03-19 09:13:40 -06:00
Jack Forgash
e9dd16f514
inc batches (#304) 2024-03-18 21:47:04 -06:00
Jack Forgash
a710a8d824
incr sql limit (#303) 2024-03-18 19:40:54 -06:00
Jack Forgash
6f52a2f548
upd txs nv 18 (#302) 2024-03-18 18:52:12 -06:00
Jack Forgash
498d590dc8
backfill - upd batch sizing (#300)
* upd batch sizing

* upd txs nv 19
2024-03-18 16:04:23 -06:00
Jack Forgash
a531ee5c98
upd txs away from batch (#299) 2024-03-18 11:28:23 -06:00
WHYTEWYLL
537a8b57c0
v2 to v1 (#296) 2024-03-14 19:25:31 -06:00
WHYTEWYLL
022390ebdc
Fix target (#295)
* hardcoding v2

* v2
2024-03-14 18:58:58 -06:00
WHYTEWYLL
131146940b
hardcoding v2 (#294) 2024-03-14 18:34:20 -06:00
WHYTEWYLL
0dee1c27e9
adding batch methods for chain and cronjob (#284)
Finetune
2024-03-14 15:38:49 -06:00
Shah Newaz Khan
3d493da486
Stream 803/throughput tune mn 18 (#283)
* add var read for invoke streams

* WIP throughput tune

* added mn 19 batch model

* remove transient tx-results-batch bronze table

* add concurent_requests

---------

Co-authored-by: shah <info@shahnewazkhan.ca>
2024-03-08 14:50:04 -08:00
Shah Newaz Khan
0d3128f868
Stream 798/tx batch tuning (#280)
* adds tx result batch make directive | bronze make directive

* batch tx_results success

* revert collections bronze scope

* revert tx results history bronze

---------

Co-authored-by: shah <info@shahnewazkhan.ca>
2024-03-04 13:33:25 -08:00
eric-laurello
5734a9b743
fix inc stats models (#281) 2024-03-01 14:40:47 -05:00
WHYTEWYLL
989fdb6cfa
add stats flow, gas pending (#279)
* add stats flow, gas pending

* fee to table

* stats flow

* fix float, schedule
2024-02-26 16:13:58 -03:00
WHYTEWYLL
3cc7463512
semicolumn (#278) 2024-02-21 07:21:05 -03:00
WHYTEWYLL
6b65655da8
Finetune (#277)
* test a from the base line on env var

* quotes

* fine tune trasnactions and results

* format

* error

* increasing producer_batch_size

* add: transactions mainnet

* mainet 18

* reducing job

* var del

* increasing producer batch size

* increasing batch size and worker

* workers limit

* reducing producer

* add fin

* fix doubled key values
2024-02-20 12:07:10 -03:00
WHYTEWYLL
7384530ccf
Finetune (#276)
* test a from the base line on env var

* quotes

* fine tune trasnactions and results

* format

* error

* increasing producer_batch_size

* add: transactions mainnet

* mainet 18

* reducing job

* var del

* increasing producer batch size

* increasing batch size and worker

* workers limit

* reducing producer
2024-02-15 20:03:40 -03:00
WHYTEWYLL
4a723f90c5
Finetune (#275)
* test a from the base line on env var

* quotes

* fine tune trasnactions and results

* format

* error

* increasing producer_batch_size

* add: transactions mainnet

* mainet 18

* reducing job

* var del

* increasing producer batch size

* increasing batch size and worker

* workers limit
2024-02-15 19:18:36 -03:00
WHYTEWYLL
99d1e0812a
Finetune (#274)
* test a from the base line on env var

* quotes

* fine tune trasnactions and results

* format

* error

* increasing producer_batch_size

* add: transactions mainnet

* mainet 18

* reducing job

* var del

* increasing producer batch size

* increasing batch size and worker
2024-02-15 19:07:37 -03:00
WHYTEWYLL
7c5cca0278
Finetune (#273)
* test a from the base line on env var

* quotes

* fine tune trasnactions and results

* format

* error

* increasing producer_batch_size

* add: transactions mainnet

* mainet 18

* reducing job

* var del

* increasing producer batch size
2024-02-15 18:09:34 -03:00
WHYTEWYLL
1043c83d4f
Finetune (#272)
* test a from the base line on env var

* quotes

* fine tune trasnactions and results

* format

* error

* increasing producer_batch_size

* add: transactions mainnet

* mainet 18

* reducing job

* var del
2024-02-15 17:08:45 -03:00
WHYTEWYLL
298a2530b9
Finetune (#271)
* test a from the base line on env var

* quotes

* fine tune trasnactions and results

* format

* error

* increasing producer_batch_size

* add: transactions mainnet

* mainet 18
2024-02-15 13:10:51 -03:00
WHYTEWYLL
17191eacd0
Finetune (#270)
* test a from the base line on env var

* quotes

* fine tune trasnactions and results

* format

* error
2024-02-14 15:07:30 -03:00
Jack Forgash
668b22097b
expliticly call putstanding NV and methods (#268) 2024-02-13 14:50:37 -07:00
WHYTEWYLL
35c6053bcd
Finetune (#266)
* test a from the base line on env var

* quotes
2024-02-13 11:30:01 -03:00
WHYTEWYLL
759836fc8d
An 4437 add or account for all day burned moments (#263)
* a

* filter previus attempts

* fix empty pack

* del filt

* severity adjust
2024-02-05 15:07:51 -03:00
WHYTEWYLL
6d53230f0a
Fix labels (#265)
* add deleted

* hotfix
2024-01-31 16:11:00 -03:00
WHYTEWYLL
39d17e3f12
add deleted (#264) 2024-01-31 14:20:56 -03:00
WHYTEWYLL
e7615a0cc6
Update labels (#262)
* a

* lavels source updated

* add core view

* unique id

* delete coalesces
2024-01-31 13:44:59 -03:00
Jack Forgash
cb95faf856
beta view w rosters (#259) 2024-01-20 14:32:15 -07:00
Jack Forgash
e0818966ad
AN-4428/add user agent to topshot and upd metadata job (#258)
* add user agent to topshot and upd metadata job

* upd agent

* upd limit to 600
2024-01-18 09:19:18 -07:00
WHYTEWYLL
59b3a5b4b5
fix: parse (#248)
* fix: parse

* fix: hex parse

* fix: format

* add: fix

* delete: last month filter

* a

* fix: parser

* delete: date filter
2024-01-16 12:09:37 -07:00
Jack Forgash
7c87cd4225
Beta allday espn id view (#255) 2024-01-05 12:57:55 -07:00
Jack Forgash
074c11c55a
fix id col in dim allday metadata (#253) 2024-01-04 09:03:25 -07:00
Jack Forgash
b26bf67732
upd desc on views (#251) 2023-12-19 17:26:19 -05:00
Jack Forgash
4c4ef12ca8
AN-4333/beta views for archiving espn ids for livequery use (#249)
* beta views for archiving espn ids for livequery use

* list cols
2023-12-19 13:40:30 -05:00
WHYTEWYLL
50962af5a5
fix: usdc mint transfers (#247)
* fix: usdc mint transfers

* format

* refactor
2023-12-18 11:57:18 -03:00
WHYTEWYLL
5c4e7bfdf8
fix: errors (#246)
* fix: errors

* format

* fix: typo
2023-12-15 07:21:42 -08:00
WHYTEWYLL
e8851383c9
Flow - add pk/inserted & modified dates/_invocation id (#239)
* add: keys core

* add: silver labels jk

* add: silver metadata jk

* add silver prices pk

* add: silver staking jk

* add: silver swaps and transfers jk

* fix: doc

* gold core pk

* gold: defi keys

* price and half nfts

* add missing comma in silver__streamline_blocks

* add: nfts

* fix: models

* list col names in swaps_events_s

* add underscore _invocation

* fix: gold layer

* delete: description

* fix: order and names

* delete: unecesarry qualify

* fix: errors

* fix: name

* dix: name

* rename id

* add: pk to topshot

* add: dim rename

* fix dim metadata views

---------

Co-authored-by: Jack Forgash <58153492+forgxyz@users.noreply.github.com>
2023-12-12 11:49:18 -08:00
Jack Forgash
28e4dd0981
upd lookback in tx res cte (#241)
* upd lookback in tx res cte

* autofmt
2023-12-06 16:13:17 -07:00
WHYTEWYLL
9dae9f240f
Pipeline metadata (#238)
* add: if condition

* removed row_list

* add:  gold view, fix macro, and silver models

* gold view extension

* add: test bronce

* g

* adding test

* add: test

* add: working test

* delete: tags

* delete: hardcode ref
2023-12-04 07:16:32 -08:00
WHYTEWYLL
150fbea1ab
fix: dedeuplicates (#237) 2023-11-29 08:44:07 -08:00
WHYTEWYLL
3e5e0a4bdd
Update silver__nft_allday_metadata_s.sql (#236) 2023-11-29 08:29:39 -08:00
WHYTEWYLL
6d6f478df6
alldaynft metadata with LQ (#229)
* base

* clean up; add: silver model

* add: new standards

* fix: refactor

* delete: folders

* refactor simplying

* remove no longer needed

* fix: refactor to silver layer

* ready to merge

---------

Co-authored-by: Desmond Hui <desmond@flipsidecrypto.com>
2023-11-27 07:55:44 -08:00
Jack Forgash
b33dc89a39
swap set description col (#232)
* swap set description col

* cast str
2023-11-20 16:39:47 -07:00
Jack Forgash
c82c04ad5d
del invocation id from gold (#231) 2023-11-20 16:30:38 -07:00
Jack Forgash
121c3e6a2c
AN-4203/ufc strike metadata (#230)
* ufc strike metadata, plus organized nft folder better

* upd db tag on gold

* upd col name to serial number

* del listing id

* add back listing id
2023-11-20 16:26:39 -07:00
Jack Forgash
821214294c
AN-4096/DEX Swaps Bug (#228)
* add event counts col to easily ignore infra events

* excl txs where to/from is null

* add tests
2023-11-15 17:15:56 -07:00
Jack Forgash
cff19a7bb6
upd test window (#227) 2023-11-14 17:42:25 -07:00
Jack Forgash
80c2462ac4
core v non-core tags and gha workflow (#225) 2023-11-10 14:30:57 -07:00
Jack Forgash
5b096dd83f
upd labels source (#223) 2023-11-07 11:48:11 -07:00
WHYTEWYLL
d17d5f06d7
deprecation (#222)
* deprecation

* del old udf creation

---------

Co-authored-by: forgash_ <jmfxyz@pm.me>
2023-11-07 10:40:24 -07:00
Jack Forgash
cc6f797d71
alter test on bitquery job (#217) 2023-10-31 11:48:27 -06:00
Jack Forgash
eb40b6d91d
Backfill Model - Incorporate all external tables (#211)
* upd sources, convert blocks to loop model, fix collections history

* multiple external tbl query macro and blocks update

* del network version.yml output

* add back rt blocks

* lower blocks

* revert str blocks and collections and move change to history view

* bronze history views and move into folders

* history workflow - blocks

* del history step from streamline blocks

* create complete get history models and upd get history streamline views - BLOCKS

* upd remaining method get history views to use history complete tables

* upd txs history dependency note

* upd history gha and del parameterized models

* fix collections external table config

* collections template fix

* upd txs templates

* upd history views

* fix to tx results template / views

* set history schedule to hourly

* del commented out backfill from streamline RT GHAs

* move blocks filter up to cte
2023-10-26 11:31:19 -06:00
desmond-hui
63ab57f844
An 4065/incremental load tuning (#215)
* modify how dbt performs merges by default

* require at least dbt 1.4

* adjust cluster keys, add incremental pred

* ensure query is being pruned on timestamp

* add cluster key
2023-10-26 07:02:53 -07:00
Jack Forgash
45a07a1da8
An 4050/txs final test (#214)
* test on str txs final for pending response

* add events final gap test

* upd test to check gaps
2023-10-24 11:52:01 -06:00
Jack Forgash
856ac1629f
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
2023-10-19 13:12:13 -06:00
Jack Forgash
19bbac48a2
Quickfix - Update retry_tx_ids in txs final (#209)
* adj greatest to handle null val

* del if null from retry_tx_ids cte

* add not null test to ins timestamp
2023-10-18 13:23:11 -06:00
Jack Forgash
a18123405e
add pending res to txs final lookback (#207) 2023-10-17 16:55:45 -06:00
Jack Forgash
ea46f3ee02
Adj Test on Beta and Upd Staking Actions (#206) 2023-10-16 18:17:45 -06:00
Jack Forgash
75901993ad
del tests from deprecating core models (#205) 2023-10-16 13:13:28 -06:00
Jack Forgash
bab9e01077
upd collections cte w lookback (#204)
* upd collections cte w lookback

* move lookback to cte
2023-10-13 16:00:16 -06:00
Jack Forgash
753c91d4fa
An 4030/obs model migration (#203)
* upd to streamline models

* add start block var
2023-10-13 13:29:24 -06:00
Jack Forgash
be73c9ba99
Upd workflows for streamline models. Disables CW models. (#202)
* upd workflows for streamline models. Disables CW models.

* repo var

* upd tx_count null test

* ch to 6 hrs
2023-10-12 17:35:59 -06:00
Jack Forgash
bd08ee7f8f
An 4015/streamline cutover (#200)
* core views

* defi schema

* bridge test upd

* gov schema

* nft schema

* price schema

* move tx count to blocks model

* add collection_count_agg to blocks

* upd core views to UNION ALL

* upd collections cluster_by

* upd dim moment metadata to qualify

* upd dim moment metadata test

* upd core dim contract labels to qualify and silver (cw) to incr

* upd str blocks lookback`
2023-10-12 16:23:20 -06:00
Jack Forgash
964f14ab16
upd expiring model to incl usdc (#201) 2023-10-12 09:35:00 -06:00
Jack Forgash
af9a6912ab
del+ins (#199) 2023-10-10 15:56:28 -06:00
Jack Forgash
17bb26999c
Upd tags on workflow to include silver__streamline_events (#198)
* upd tags on scheduled run

* cron to 30 mins
2023-10-10 15:35:43 -06:00
Jack Forgash
50b61ee6d8
add col (#197) 2023-10-10 13:35:09 -06:00
Jack Forgash
792f11599f
AN-3903/Migration Reorg (#196)
* txs final and upd streamline tests w 1 hr inserted timestamp buffer

* copy silver models into silver_cw dir

* txs final, events model, curated model _s copies

* add pending col to txs final

* test config for pending_result_response

* add coalesce to tx id in txs final

* rem tests on inserted timestamp

* uppercase gap test vars

* add retry for null block timestamp and del mainnet23 filter from events

* address adj append 0x, add network ver to blocks, etc

* upd coalesce on events data

* saving event migration test, disabled

* req changes

* upd txs final ingested logic
2023-10-10 13:24:43 -06:00
Jack Forgash
d28d09f53e
AN-3939/add fix gap logic and obs models tests (#195)
* add fix gap logic and obs models tests

* block height recency test on bitquery table

* add tag

* upd workflow

* explicit cast as int
2023-09-15 13:45:28 -06:00
Shah Newaz Khan
c663e7523e
lq & udf_api overload deploy (#186)
* lq overload deploy success

* fixed make directive line continuation

---------

Co-authored-by: shah <info@shahnewazkhan.ca>
2023-09-13 10:26:37 -07:00
Jack Forgash
9386c2af39
Streamline rt - flip blocks priority to desc (#191)
* add desc to RT model to prioritize CH

* flip to desc
2023-09-11 17:09:00 -06:00
Jack Forgash
ad70599d38
upd rt tx results to ohio (#190) 2023-09-08 20:03:46 -06:00
Shah Newaz Khan
bfa514ed7e
added multi region udfs (#189)
Co-authored-by: shah <info@shahnewazkhan.ca>
2023-09-08 18:50:28 -07:00
Jack Forgash
fe7c2b724b
AN-3890/migrate udf (#188)
* upd to live

* migrate to new udf_api deployment

* adjust metadata schedule to daily
2023-09-08 12:52:40 -06:00
Jack Forgash
b1f0925a90
AN-3712/Metadata livequery (#146)
* topshot metadata pull v1

* before swap from lambda

* ready for stress test / batch sizing tmrw

* define unique key in helper tbl

* typo

* add todo deloy udf_api

* slight format tweak

* named

* migrate to livequery schema

* add parameter yml

* add livequery model yml, need tests

* alter metadata job run

* del old streamline macros

* silver upd - in flight

* clean up py model

* limit comment

* revert silver topshot metadata

* new silver model

* union new lq data into nft metadata table(s)

* del block_timestamp from metadata needed view

* untag silver nft allday metadata

* set limit to 3500

* addback topshot tag

* update schedule to hourly
2023-09-07 10:13:02 -06:00
Jack Forgash
f3f362ef54
Add 3 Mainnets 19-21 to Blocks (#182) 2023-09-05 16:44:07 -06:00
Jack Forgash
aca459a005
AN-3898/fix qualify in silver load models (#181)
* fix qualify

* del txs alias
2023-09-05 13:42:49 -06:00
Jack Forgash
92089f7b84
incr limit to 1m (#178) 2023-09-01 18:27:07 -06:00
Jack Forgash
7608c1c611
add last_3_days filter, rem tbl (#177)
* add last_3_days filter, rem tbl

* max

* rem max
2023-09-01 15:03:15 -06:00
Jack Forgash
eca7813bae
Tx Result Status + Run RT Only, at increased interval (#176)
* add tx status filter commented and comment out blocks filter

* incr frequency of RT models

* typo

* format block
2023-08-31 16:26:04 -06:00
Jack Forgash
feded0669f
disregard unsealed current mainnet blocks (#175)
* disregard unsealed current mainnet blocks

* root height from seeds

* move alias
2023-08-31 15:45:06 -06:00
Jack Forgash
caf9f4804c
An 3780/schema reorg (#153)
* folder structures

* new views

* update docs overview

* upd sources

* upd sources and move silver from base to core

* del flipside prod db prices v2

* add scheduled tag to new views
2023-08-31 10:38:17 -06:00
Jack Forgash
b55f82f5ad uncomment RT limit 2023-08-30 18:01:21 -06:00
Jack Forgash
3f3c841115
add limit and col alias to blocks rt (#172)
* add limit and col alias to blocks

* comment out limit
2023-08-30 15:17:28 -06:00
Jack Forgash
38b4e4abc9
upd start height of realtime to mainnet23 root height and add STREAMLINE_RUN_HISTORY to GHA (#171)
* upd start height of realtime to mainnet23 root height and add "STREAMLINE_RUN_HISTORY": True

* add select
2023-08-30 11:06:30 -06:00
WHYTEWYLL
6ce17a7219
Streamline Realtime and Backfill Models (#156)
* add: model to backfill

* fix: node's string format

* add tags

* upd collection model

* mainnet21 hardcoded collections history model

* del tag

* mainnet 21 getblock

* tag for 21

* realtime models

* alias num as height

* realtime tags

* add missing tag and newlines

* backfiller

* backfiller

* move script to folder (renamed) python, upd test accordingly w dir name ch

* upd script to accept model input, update jobs per method call

* error w use_dev arg

* add: silver mdoels

* limit backfill job in python script

* rename silver dbt models to streamline_ and move into silver/core

* explicit casting to silver streamline models

* add documentation to silver streamline models

* run only current mainnet and history mainnet 22 first

* activate schedule for gha

* del hardcoded mainnet models

* move history modes out of subdirs into history dir

* fix GHA vars

* del upstream 1+ from history step

* del tag

---------

Co-authored-by: Jack Forgash <jmfxyz@pm.me>
2023-08-30 08:38:01 -06:00
Jack Forgash
66ba1c1d59
add fr false to obs (#168) 2023-08-28 16:09:25 -06:00
Jack Forgash
d484b0e164
add fr false (#167) 2023-08-28 16:00:47 -06:00
Jack Forgash
6b94cb4234
remove underscore (#166) 2023-08-28 15:59:11 -06:00
Jack Forgash
51951df051
An 3859/obs model on (#163)
* obs models on

* rename workflow
2023-08-28 10:02:13 -06:00
Jack Forgash
45f72e71d8
An 3660/observability models (#155)
* blocks completeness

* block tx count external api model

* txs completeness model

* add col alias

* test result agg cte and temp test range

* curr range test

* revert source change - other pr

* xchain silver

* nuke api key & move to secrets, create workflow

* add scheduled tag

* update workflow w cache

* add obs tag

* rem testing range from txs complete

* comment out schedule and del double comman

* add default null for key var
2023-08-23 13:37:16 -06:00
Shah Newaz Khan
7e98bd6029
bug fix for non block spine coll/tx ingestion (#157)
Co-authored-by: shah <info@shahnewazkhan.ca>
2023-08-23 12:13:40 -07:00
Shah Newaz Khan
f3a5b863e1
Stream 392 fix prod (#154)
* node url join optimized | warehouse privilege grants

* added udf api

* revert udtf alias

* fixed incremental complete runs

* node url join optimized | warehouse privilege grants

* added udf api

* reverted case insentive filename changes

---------

Co-authored-by: shah <info@shahnewazkhan.ca>
2023-08-22 12:01:55 -07:00
Shah Newaz Khan
1beb5f8ad6
Stream 392 lq udf (#151)
* node url join optimized | warehouse privilege grants

* added udf api

* revert udtf alias

---------

Co-authored-by: shah <info@shahnewazkhan.ca>
2023-08-22 10:29:42 -07:00
Shah Newaz Khan
2413473512
GHA & Backfill Docs (#149)
* node url join optimized | warehouse privilege grants

* added string interpolation for env based target.database

* revert to candidate node 7 root height

* collections history success

* removed end height from network_version

* removed EOF

* added prod udf

* added tx & tx_result backfill models

* adds FR models

* add prod api integraton

* switched dev flag off

* added gha & docs

* updated serialization png

* added tx specific gha model selection

---------

Co-authored-by: shah <info@shahnewazkhan.ca>
2023-08-16 15:57:04 -07:00
Shah Newaz Khan
fe7f688cc2
Stream 98 collection backfill (#145)
* node url join optimized | warehouse privilege grants

* added string interpolation for env based target.database

* revert to candidate node 7 root height

* collections history success

* removed end height from network_version

* removed EOF

* added prod udf

---------

Co-authored-by: shah <info@shahnewazkhan.ca>
2023-08-10 14:23:29 -07:00
Shah Newaz Khan
d14843bd0c
Stream 98 fix nodeurl (#141)
* fixed node urls

* limited streamline_blocks to candidate node 7 root height

---------

Co-authored-by: shah <info@shahnewazkhan.ca>
2023-08-03 12:30:13 -07:00
Jack Forgash
67790931a4
Quickfix 080323/bad cast (#142)
* update cast to str

* add second str cast

* int
2023-08-03 11:07:39 -06:00
Shah Newaz Khan
b344373700
Stream 98 node url seed (#138)
* added clone purge fix make directive

* fixed json parsing for get blocks history

* added aws_lambda_role envar to undo_clone directive | added database grants to lambda role

* get_node_url parsing error

* fixed varchar return type for get_node_url

* node mapping window function success

* removed get_node_url macro | added node_url seed

* removed debug logs | removed create node_url macro

* added filter to node_mapping CTE

* Update models/silver/streamline/core/streamline__blocks.sql

* fixed merge conflict

* Reduce columns for get_blocks_history

---------

Co-authored-by: shah <info@shahnewazkhan.ca>
2023-08-01 14:56:15 -07:00
Jack Forgash
12e951471d
upd slack msg (#139)
* upd slack msg

* Update dbt_test_alert.py

* !

* alter tests
2023-08-01 10:29:14 -06:00
Shah Newaz Khan
4a1596b0d0
Stream 97 blocks assembly (#134)
* added clone purge fix make directive

* fixed json parsing for get blocks history

* added aws_lambda_role envar to undo_clone directive | added database grants to lambda role

* removed debug logs

---------

Co-authored-by: shah <info@shahnewazkhan.ca>
2023-07-31 12:54:18 -07:00
Jack Forgash
7552fb7dfe
seed and test adj (#133)
* seed and test adj

* rm_typo
2023-07-25 11:00:32 -06:00
Shah Newaz Khan
e39845bc3d
Stream 97 streamline blocks (#129)
* udf_bulk_grpc success

* removed test analysis sql

---------

Co-authored-by: shah <info@shahnewazkhan.ca>
2023-07-24 09:24:52 -07:00
Shah Newaz Khan
cecced9db1
streamline flow chainhead udf (#128)
* added makefile udf/api integration directives | added api integration / udf macros

* added reamdme comments

---------

Co-authored-by: shah <info@shahnewazkhan.ca>
2023-07-18 13:04:21 -07:00
WHYTEWYLL
de09e6e00f
add: 248 celer id (#127) 2023-06-27 12:07:39 -07:00
Jack Forgash
d25b02df55
Prices from Swaps update (#126)
* workflow_prod and core->gold

* update prices from swaps
2023-06-07 16:42:53 -06:00
Jack Forgash
dce8ba2ec9
move allday error filter to silver (#124) 2023-06-07 13:45:07 -04:00
Jack Forgash
59d72bfea8
add utils package (#122)
* add utils package

* add create udfs

* rename core dir to gold

* vars->inputs
2023-06-06 10:42:38 -06:00
Jack Forgash
0e5f837448
tx gaps off (#121) 2023-05-24 08:24:09 -06:00
Jack Forgash
c4f5ac129d
remove threshold (#120)
* remove threshold

* cast date
2023-05-05 14:04:12 -06:00