retry

.github/workflows/dbt_test_intraday.yml

@@ -0,0 +1,48 @@
+name: dbt_test_intraday
+run-name: dbt_test_intraday
+
+on:
+  workflow_dispatch:
+  schedule:
+    # Runs “At minute 5 past every 4th hour.” (see https://crontab.guru)
+    - cron: '5 */4 * * *'
+    
+env:
+  DBT_PROFILES_DIR: ./
+
+  ACCOUNT: "${{ vars.ACCOUNT }}"
+  ROLE: "${{ vars.ROLE }}"
+  USER: "${{ vars.USER }}"
+  PASSWORD: "${{ secrets.PASSWORD }}"
+  REGION: "${{ vars.REGION }}"
+  DATABASE: "${{ vars.DATABASE }}"
+  WAREHOUSE: "${{ vars.WAREHOUSE }}"
+  SCHEMA: "${{ vars.SCHEMA }}"
+
+concurrency:
+  group: ${{ github.workflow }}
+  
+jobs:
+  run_dbt_jobs:
+    runs-on: ubuntu-latest
+    environment: 
+      name: workflow_test
+
+    steps:
+      - uses: actions/checkout@v3
+
+      - uses: actions/setup-python@v4
+        with:
+          python-version: "3.10"
+          cache: "pip"
+
+      - name: install dependencies
+        run: |
+          pip install -r requirements.txt
+          dbt deps
+      - name: Run DBT Jobs
+        run: |
+          dbt test -m "berachain_models,tag:recent_test"
+  
+
+

models/streamline/core/realtime/streamline__testnet_receipts_realtime.sql

@@ -32,6 +32,16 @@ ready_blocks AS (
         block_number
     FROM
         to_do
+    UNION
+    SELECT
+        block_number
+    FROM
+        {{ ref("_missing_receipts") }}
+    UNION
+    SELECT
+        block_number
+    FROM
+        {{ ref("_missing_txs") }}
 )
 SELECT
     block_number,

models/streamline/core/realtime/streamline__testnet_traces_realtime.sql

@@ -32,6 +32,11 @@ ready_blocks AS (
         block_number
     FROM
         to_do
+    UNION
+    SELECT
+        block_number
+    FROM
+        {{ ref("_missing_traces") }}
 )
 SELECT
     block_number,

models/streamline/core/realtime/streamline__testnet_transactions_realtime.sql

@@ -32,6 +32,11 @@ ready_blocks AS (
         block_number
     FROM
         to_do
+    UNION
+    SELECT
+        block_number
+    FROM
+        {{ ref("_missing_txs") }}
 )
 SELECT
     block_number,