add empty check (#7462)

duneanalytics · Jan 14, 2025 · 8730fcc · 8730fcc
1 parent 15ff6d4
commit 8730fcc
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 1 deletion.
diff --git a/dbt_subprojects/dex/models/_projects/bebop/arbitrum/bebop_rfq_arbitrum_trades.sql b/dbt_subprojects/dex/models/_projects/bebop/arbitrum/bebop_rfq_arbitrum_trades.sql
@@ -1,7 +1,6 @@
 {{ config(
     schema = 'bebop_rfq_arbitrum',
     alias = 'trades',
-    tags = ['prod_exclude'],
     partition_by = ['block_month'],
     materialized = 'incremental',
     file_format = 'delta',
@@ -58,6 +57,8 @@ bebop_raw_data AS (
     {% if is_incremental() %}
     AND {{ incremental_predicate('evt.evt_block_time') }}
     {% endif %}
+    AND json_array_length(json_extract((JSON_EXTRACT(ex."order", '$.maker_tokens')), '$[0]')) > 0
+    AND json_array_length(json_extract((JSON_EXTRACT(ex."order", '$.taker_tokens')), '$[0]')) > 0
 ),
 
 unnested_array_taker AS (

diff --git a/dbt_subprojects/dex/models/_projects/bebop/ethereum/bebop_rfq_ethereum_trades.sql b/dbt_subprojects/dex/models/_projects/bebop/ethereum/bebop_rfq_ethereum_trades.sql
@@ -57,6 +57,8 @@ bebop_raw_data AS (
     {% if is_incremental() %}
     AND {{ incremental_predicate('evt.evt_block_time') }}
     {% endif %}
+    AND json_array_length(json_extract((JSON_EXTRACT(ex."order", '$.maker_tokens')), '$[0]')) > 0
+    AND json_array_length(json_extract((JSON_EXTRACT(ex."order", '$.taker_tokens')), '$[0]')) > 0
 ),
 
 unnested_array_taker AS (

diff --git a/dbt_subprojects/dex/models/_projects/bebop/optimism/bebop_rfq_optimism_trades.sql b/dbt_subprojects/dex/models/_projects/bebop/optimism/bebop_rfq_optimism_trades.sql
@@ -50,6 +50,8 @@ bebop_raw_data AS (
     {% if is_incremental() %}
     AND {{ incremental_predicate('evt.evt_block_time') }}
     {% endif %}
+    AND json_array_length(json_extract((JSON_EXTRACT(ex."order", '$.maker_tokens')), '$[0]')) > 0
+    AND json_array_length(json_extract((JSON_EXTRACT(ex."order", '$.taker_tokens')), '$[0]')) > 0
 ),
 
 unnested_array_taker AS (

diff --git a/dbt_subprojects/dex/models/_projects/bebop/polygon/bebop_rfq_polygon_trades.sql b/dbt_subprojects/dex/models/_projects/bebop/polygon/bebop_rfq_polygon_trades.sql
@@ -57,6 +57,8 @@ bebop_raw_data AS (
     {% if is_incremental() %}
     AND {{ incremental_predicate('evt.evt_block_time') }}
     {% endif %}
+    AND json_array_length(json_extract((JSON_EXTRACT(ex."order", '$.maker_tokens')), '$[0]')) > 0
+    AND json_array_length(json_extract((JSON_EXTRACT(ex."order", '$.taker_tokens')), '$[0]')) > 0
 ),
 
 unnested_array_taker AS (