fix: add anomaly_status in dbt models (#2920)

Author: Datayama38

dbt/models/observatoire/carpool_by_day.sql

@@ -52,6 +52,7 @@ LEFT JOIN
 WHERE
   a.acquisition_status = 'processed'
   AND a.fraud_status = 'passed'
+  AND a.anomaly_status = 'passed'
 {% if is_incremental() %}
   AND a.start_datetime::date >= (SELECT MAX(start_date) FROM {{ this }})::date
 {% endif %}

dbt/models/observatoire/carpool_incentive_by_day.sql

@@ -40,6 +40,7 @@ JOIN
 WHERE
   a.acquisition_status = 'processed'
   AND a.fraud_status = 'passed'
+  AND a.anomaly_status = 'passed'
 {% if is_incremental() %}
   AND a.start_datetime::date >= (SELECT MAX(start_date) FROM {{ this }})::date
 {% endif %}

dbt/models/observatoire/carpool_newcomer_by_day.sql

@@ -42,6 +42,7 @@ LEFT JOIN
 WHERE
   a.acquisition_status = 'processed'
   AND a.fraud_status = 'passed'
+  AND a.anomaly_status = 'passed'
 {% if is_incremental() %}
   AND a.start_datetime::date >= (SELECT MAX(start_date) FROM {{ this }})::date
 {% endif %}

dbt/models/observatoire/view_carpool.sql

@@ -12,6 +12,7 @@ SELECT
   a.passenger_payments,
   b.acquisition_status,
   b.fraud_status,
+  b.anomaly_status,
   CASE
     WHEN
       c.start_geo_code::text ~ '^97[1-2]'::text
@@ -63,4 +64,4 @@ WHERE
   c.start_geo_code IS NOT NULL
   AND c.end_geo_code IS NOT NULL
   AND date_part('year', a.start_datetime) >= 2020
-  AND a.start_datetime < now() - INTERVAL '8' DAY
+  AND a.start_datetime < now() - INTERVAL '2' DAY

dbt/models/observatoire/view_distribution.sql

@@ -26,4 +26,5 @@ select
     ON a.end_geo_code = c.old_com
   WHERE
     a.acquisition_status = 'processed'
-    AND a.fraud_status = 'passed'
+    AND a.fraud_status = 'passed'
+    AND a.anomaly_status = 'passed'

dbt/models/observatoire/view_first_date_driver.sql

@@ -7,4 +7,5 @@ from {{ ref('view_carpool') }}
 where
   acquisition_status = 'processed'
   and fraud_status = 'passed'
+  and anomaly_status = 'passed'
 group by driver_id

dbt/models/observatoire/view_first_date_passenger.sql

@@ -7,4 +7,5 @@ from {{ ref('view_carpool') }}
 where
   acquisition_status = 'processed'
   and fraud_status = 'passed'
+  and anomaly_status = 'passed'
 group by passenger_id

dbt/models/observatoire/view_location.sql

@@ -46,6 +46,7 @@ LEFT JOIN
   ON c.end_geo_code = e.old_com
 WHERE
   date_part('year', a.start_datetime) >= 2020
-  AND a.start_datetime < now() - INTERVAL '8' DAY
+  AND a.start_datetime < now() - INTERVAL '2' DAY
   AND b.acquisition_status = 'processed'
   AND b.fraud_status = 'passed'
+  AND b.anomaly_status = 'passed'