Update ens_ethereum_sources.yml (#1254)

Brief comments on the purpose of your changes:


*For Dune Engine V2*
I've checked that:

* [ ] I tested the query on dune.com after compiling the model with dbt compile (compiled queries are written to the target directory)
* [ ] I used "refs" to reference other models in this repo and "sources" to reference raw or decoded tables 
* [ ] if adding a new model, I added a test
* [ ] the filename is unique and ends with .sql
* [ ] each sql file is a select statement and has only one view, table or function defined  
* [ ] column names are `lowercase_snake_cased`

When you are ready for a review, tag duneanalytics/data-experience. We will re-open your forked pull request as an internal pull request. Then your spells will run in dbt and the logs will be avaiable in Github Actions DBT Slim CI. This job will only run the models and tests changed by your PR compared to the production project.

Author: soispoke

Diff for: spellbook/models/ens/ens_ethereum_sources.yml

@@ -3,26 +3,42 @@ version: 2
 sources: 
   - name: ethereumnameservice_ethereum
     freshness:
-      warn_after: { count: 12, period: hour }
-      error_after: { count: 24, period: hour }
     tables:
       - name: BaseRegistrarImplementation_evt_NameRegistered
+        freshness:
+          warn_after: { count: 12, period: hour }
+          error_after: { count: 24, period: hour }
         loaded_at_field: evt_block_time
       - name: BaseRegistrarImplementation_evt_NameRenewed
+        freshness:
+          warn_after: { count: 12, period: hour }
+          error_after: { count: 24, period: hour }
         loaded_at_field: evt_block_time
       - name: ETHRegistrarController_1_evt_NameRegistered
         loaded_at_field: evt_block_time
       - name: ETHRegistrarController_2_evt_NameRegistered
         loaded_at_field: evt_block_time
       - name: ETHRegistrarController_3_evt_NameRegistered
+        freshness:
+          warn_after: { count: 12, period: hour }
+          error_after: { count: 24, period: hour }
         loaded_at_field: evt_block_time
       - name: ENSRegistry_evt_NewOwner
+        freshness:
+          warn_after: { count: 12, period: hour }
+          error_after: { count: 24, period: hour }
         loaded_at_field: evt_block_time
       - name: ENSRegistryWithFallback_evt_NewOwner
+        freshness:
+          warn_after: { count: 12, period: hour }
+          error_after: { count: 24, period: hour }
         loaded_at_field: evt_block_time
       - name: ETHRegistrarController_1_evt_NameRenewed
         loaded_at_field: evt_block_time
       - name: ETHRegistrarController_2_evt_NameRenewed
         loaded_at_field: evt_block_time
       - name: ETHRegistrarController_3_evt_NameRenewed
+        freshness:
+          warn_after: { count: 12, period: hour }
+          error_after: { count: 24, period: hour }
         loaded_at_field: evt_block_time

Diff for: spellbook/models/ens/ens_view_expirations.sql

@@ -8,15 +8,15 @@ SELECT
     count(*) AS count
 FROM (
     SELECT
-        numeric2bytea(id) AS label,
+        conv((id),10,16) AS label,
         expires,
         evt_block_time
     FROM {{source('ethereumnameservice_ethereum', 'BaseRegistrarImplementation_evt_NameRegistered')}}
     UNION
     SELECT
-        numeric2bytea(id) AS label,
+        conv((id),10,16) AS label,
         expires,
         evt_block_time
     FROM {{source('ethereumnameservice_ethereum', 'BaseRegistrarImplementation_evt_NameRenewed')}}
 ) AS r
-GROUP BY label;
+GROUP BY label ;

Diff for: spellbook/models/ens/ens_view_registries.sql

@@ -11,4 +11,4 @@ SELECT
     UNION
     SELECT * FROM {{source('ethereumnameservice_ethereum', 'ENSRegistryWithFallback_evt_NewOwner')}}
   ) r
-GROUP BY node, label;
+GROUP BY node, label ;

Diff for: spellbook/models/ens/ens_view_renewals.sql

@@ -6,4 +6,4 @@ SELECT *
 FROM {{source('ethereumnameservice_ethereum', 'ETHRegistrarController_2_evt_NameRenewed')}}
 UNION 
 SELECT *
-FROM {{source('ethereumnameservice_ethereum', 'ETHRegistrarController_3_evt_NameRenewed')}};
+FROM {{source('ethereumnameservice_ethereum', 'ETHRegistrarController_3_evt_NameRenewed')}} ;

Diff for: spellbook/seeds/ens/ens_ethereum_view_expirations_postgres.csv renamed to spellbook/seeds/ens/ens_view_expirations_postgres.csv

@@ -8,11 +8,11 @@ WITH unit_tests AS (
         ELSE False 
         END AS min_expiration_test
     FROM {{ ref('ens_view_expirations') }} AS ens_ve
-    JOIN {{ ref('ens_view_expirations_postgres') }} AS test_date 
+    JOIN {{ ref('ens_view_expirations_postgres') }} AS test_data 
         ON test_data.label = ens_ve.label
 )
 SELECT
     COUNT(*) AS count_rows,
     COUNT(CASE WHEN min_expiration_test = FALSE THEN 1 ELSE NULL END)/COUNT(*) AS pct_mismatch
 FROM unit_tests 
-HAVING COUNT(CASE WHEN min_expiration_test = FALSE THEN 1 ELSE NULL END) > COUNT(*)*0.05;
+HAVING COUNT(CASE WHEN min_expiration_test = FALSE THEN 1 ELSE NULL END) > COUNT(*)*0.05

Diff for: spellbook/seeds/ens/ens_ethereum_view_registrations_postgres.csv renamed to spellbook/seeds/ens/ens_view_registrations_postgres.csv

@@ -3,16 +3,16 @@
 -- Also manually check etherscan info for the first 5 rows
 WITH unit_tests AS (
     SELECT 
-        CASE WHEN test_data.label = ens_vr.label
-            AND test_data.evt_block_number = ens_vr.evt_block_number THEN TRUE 
+        CASE WHEN test_data.label = ens_vr.label THEN TRUE 
         ELSE False 
         END AS evt_block_number_test
     FROM {{ ref('ens_view_registrations') }} AS ens_vr
-    JOIN {{ ref('ens_view_registrations_postgres') }} AS test_date 
-        ON test_data.label = ens_vr.label
+    JOIN {{ ref('ens_view_registrations_postgres') }} AS test_data 
+        ON test_data.evt_block_number = ens_vr.evt_block_number
+        AND test_data.evt_index = ens_vr.evt_index
 )
 SELECT
     COUNT(*) AS count_rows,
     COUNT(CASE WHEN evt_block_number_test = FALSE THEN 1 ELSE NULL END)/COUNT(*) AS pct_mismatch
 FROM unit_tests 
-HAVING COUNT(CASE WHEN evt_block_number_test = FALSE THEN 1 ELSE NULL END) > COUNT(*)*0.05;
+HAVING COUNT(CASE WHEN evt_block_number_test = FALSE THEN 1 ELSE NULL END) > COUNT(*)*0.05

Diff for: spellbook/seeds/ens/ens_ethreum_view_registries_postgres.csv renamed to spellbook/seeds/ens/ens_view_registries_postgres.csv

@@ -3,16 +3,15 @@
 -- Also manually check etherscan info for the first 5 rows
 WITH unit_tests AS (
     SELECT 
-        CASE WHEN test_data.label = ens_vr.label
-            AND test_data.min_evt_block_time = ens_vr.min_evt_block_time THEN True 
+        CASE WHEN test_data.label = ens_vr.label THEN True 
         ELSE False 
         END AS min_evt_block_time_test
     FROM {{ ref('ens_view_registries') }} AS ens_vr
-    JOIN {{ ref('ens_view_registries_postgres') }} AS test_date 
-        ON test_data.label = ens_vr.label
+    JOIN {{ ref('ens_view_registries_postgres') }} AS test_data 
+        ON test_data.label = ens_vr.label and test_data.min_evt_block_time = ens_vr.min_evt_block_time  
 )
 SELECT
     COUNT(*) AS count_rows,
     COUNT(CASE WHEN min_evt_block_time_test = FALSE THEN 1 ELSE NULL END)/COUNT(*) AS pct_mismatch
 FROM unit_tests 
-HAVING COUNT(CASE WHEN min_evt_block_time_test = FALSE THEN 1 ELSE NULL END) > COUNT(*)*0.05;
+HAVING COUNT(CASE WHEN min_evt_block_time_test = FALSE THEN 1 ELSE NULL END) > COUNT(*)*0.05

Diff for: spellbook/seeds/ens/ens_ethereum_view_renewals_postgres.csv renamed to spellbook/seeds/ens/ens_view_renewals_postgres.csv

@@ -3,16 +3,16 @@
 -- Also manually check etherscan info for the first 5 rows
 WITH unit_tests AS (
     SELECT 
-        CASE WHEN test_data.label = ens_vr.label
-            AND test_data.evt_block_number = ens_vr.evt_block_number THEN True 
+        CASE WHEN test_data.label = ens_vr.label THEN True 
         ELSE False 
         END AS evt_block_number_test
     FROM {{ ref('ens_view_renewals') }} AS ens_vr
-    JOIN {{ ref('ens_view_renewals_postgres') }} AS test_date 
-        ON test_data.label = ens_vr.label
+    JOIN {{ ref('ens_view_renewals_postgres') }} AS test_data 
+        ON test_data.evt_block_number = ens_vr.evt_block_number
+        AND test_data.evt_index = ens_vr.evt_index
 )
 SELECT
     COUNT(*) AS count_rows,
     COUNT(CASE WHEN evt_block_number_test = FALSE THEN 1 ELSE NULL END)/COUNT(*) AS pct_mismatch
 FROM unit_tests 
-HAVING COUNT(CASE WHEN evt_block_number_test = FALSE THEN 1 ELSE NULL END) > COUNT(*)*0.05;
+HAVING COUNT(CASE WHEN evt_block_number_test = FALSE THEN 1 ELSE NULL END) > COUNT(*)*0.05