fix: filter out non USD transactions

opensource-observer · Sep 24, 2024 · de3834c · de3834c
1 parent 5a41ecf
commit de3834c
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/warehouse/dbt/models/staging/open-collective/stg_open_collective__events.sql b/warehouse/dbt/models/staging/open-collective/stg_open_collective__events.sql
@@ -1,9 +1,13 @@
 with open_collective_expenses as (
-  select * from {{ open_collective_events("stg_open_collective__expenses") }}
+  select *
+  from {{ open_collective_events("stg_open_collective__expenses") }}
+  where JSON_VALUE(amount, "$.currency") = "USD"
 ),
 
 open_collective_deposits as (
-  select * from {{ open_collective_events("stg_open_collective__deposits") }}
+  select *
+  from {{ open_collective_events("stg_open_collective__deposits") }}
+  where JSON_VALUE(amount, "$.currency") = "USD"
 )
 
 select * from open_collective_expenses