Skip to content

Commit

Permalink
An 5714/traces2 hotswap base (#247)
Browse files Browse the repository at this point in the history
* make hotswap changes

* replace with source

* remove old and undelete traces2 fix

* add traces2fix

* add sources

* add tests

* overflow

* tests

* missing traces test

---------

Co-authored-by: Austin <[email protected]>
  • Loading branch information
sam-xyz and austinFlipside authored Jan 30, 2025
1 parent 5ea734e commit ed54d58
Show file tree
Hide file tree
Showing 46 changed files with 1,163 additions and 1,205 deletions.
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@
name: dbt_run_overflowed_traces2
run-name: dbt_run_overflowed_traces2
name: dbt_run_overflowed_traces
run-name: dbt_run_overflowed_traces

on:
workflow_dispatch:
branches:
- "main"

env:
DBT_PROFILES_DIR: ./

Expand All @@ -21,12 +21,10 @@ env:
concurrency:
group: ${{ github.workflow }}



jobs:
run_dbt_jobs:
runs-on: ubuntu-latest
environment:
environment:
name: workflow_prod

steps:
Expand All @@ -43,4 +41,4 @@ jobs:
dbt deps
- name: Run DBT Jobs
run: |
dbt run -m "base_models,tag:overflowed_traces2" --vars '{"OVERFLOWED_TRACES":True}'
dbt run -m "base_models,tag:overflowed_traces" --vars '{"OVERFLOWED_TRACES":True}'
46 changes: 0 additions & 46 deletions .github/workflows/dbt_run_traces_fix.yml

This file was deleted.

Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{{ config (
materialized = "view",
tags = ['overflowed_traces2']
tags = ['overflowed_traces']
) }}

{% for item in range(
Expand Down Expand Up @@ -47,7 +47,7 @@
index_cols
) AS index_vals
FROM
{{ ref("bronze__potential_overflowed_traces2") }}
{{ ref("bronze__potential_overflowed_traces") }}
WHERE
row_no = {{ item }}
),
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{{ config (
materialized = "view",
tags = ['overflowed_traces2']
tags = ['overflowed_traces']
) }}

WITH impacted_blocks AS (
Expand Down Expand Up @@ -38,15 +38,18 @@ missing_txs AS (
file_name
FROM
all_txs txs
LEFT JOIN {{ ref("silver__traces2") }}
LEFT JOIN {{ source(
'base_gold',
'fact_traces'
) }}
tr2 USING (
block_number,
tx_position
)
JOIN {{ ref("streamline__traces_complete") }} USING (block_number)
LEFT JOIN {{ source(
'base_silver',
'overflowed_traces2'
'overflowed_traces'
) }}
ot USING (
block_number,
Expand Down
Loading

0 comments on commit ed54d58

Please sign in to comment.