updates (#236)

.github/workflows/dbt_run_abi_refresh.yml

@@ -3,9 +3,8 @@ run-name: dbt_run_abi_refresh
 
 on:
   workflow_dispatch:
-  schedule:
-    # Runs “At minute 35 past every 12th hour.” (see https://crontab.guru)
-    - cron: '35 */12 * * *'
+    branches:
+      - "main"
 
 env:
   DBT_PROFILES_DIR: ./
@@ -42,9 +41,11 @@ jobs:
         run: |
           pip install -r requirements.txt
           dbt deps
-      - name: Run DBT Jobs
+
+      - name: Update ABI models
         run: |
           dbt run -m "base_models,tag:abis"
   
-
-
+      - name: Kick off decoded logs history, if there are new ABIs from users
+        run: |
+          dbt run-operation run_decoded_logs_history

data/github_actions__workflows.csv

@@ -1,8 +1,7 @@
 workflow_name,workflow_schedule
-dbt_run_scheduled_non_realtime,"22,52 * * * *"
+dbt_run_scheduled_non_realtime,"22 * * * *"
 dbt_run_streamline_chainhead,"15,45 * * * *"
-dbt_run_streamline_decoder,"0,30 * * * *"
-dbt_run_scheduled_curated,"40 * * * *"
-dbt_test_tasks,"15 * * * *"
+dbt_run_streamline_decoder,"33 * * * *"
+dbt_run_scheduled_curated,"40 */4 * * *"
 dbt_run_streamline_decoded_logs_history,"45 7 * * 6"
-dbt_run_scheduled_decoded_logs_history_user_abis,"39 23 * * *"
+dbt_run_abi_refresh,"32 23 * * *"

models/bronze/api_udf/bronze_api__contract_abis.sql

@@ -25,7 +25,7 @@ WHERE
 {% endif %}
     order by total_interaction_count desc
     LIMIT
-        50
+        400
 ), all_contracts AS (
     SELECT
         contract_address
@@ -47,7 +47,7 @@ row_nos AS (
     FROM
         all_contracts
 ),
-batched AS ({% for item in range(55) %}
+batched AS ({% for item in range(501) %}
 SELECT
     rn.contract_address, live.udf_api('GET', CONCAT('https://api.basescan.org/api?module=contract&action=getabi&address=', rn.contract_address, '&apikey={key}'),{ 'User-Agent': 'FlipsideStreamline' },{}, 'Vault/prod/block_explorers/base_scan') AS abi_data, SYSDATE() AS _inserted_timestamp
 FROM