fix #15 #17 #21 working dbt

Author: cap-amirb

dbt_repo/src/demo_project/models/ods/covid-france_ods.sql

@@ -1,13 +1,28 @@
 -- {{ config(materialized='table', schema='ods') }}
+
+with covidfrance_raw_airbyte as (
+    select
+        ab_id as id,
+        emitted_at,
+        data::json->'dc' as nb_deces,
+        data::json->'dep' as departement,
+        data::json->'rad' as nb_retours_au_domicile,
+        data::json->'rea' as nb_reanimations,
+        data::json->'hosp' as nb_hospitalisations,
+        data::json->'jour' as date_notification,
+        data::json->'sexe' as sexe
+        
+    from {{ source('stg', 'covid-france_stg') }}
+)
+
 select
-    ab_id as id,
-    emitted_at,
-    data::json->'dc' as nb_deces,
-    data::json->'dep' as departement,
-    data::json->'rad' as nb_retours_au_domicile,
-    data::json->'rea' as nb_reanimations,
-    data::json->'hosp' as nb_hospitalisations,
-    data::json->'jour' as date_notification,
-    data::json->'sexe' as sexe
-    
-from {{ source('stg', 'covid-france_stg') }}
+    id::TEXT,
+    emitted_at::DATE,
+    nb_deces::TEXT,
+    departement::TEXT,
+    nb_retours_au_domicile::TEXT,
+    nb_reanimations::TEXT,
+    nb_hospitalisations::TEXT,
+    date_notification::TEXT,
+    sexe::TEXT     
+from covidfrance_raw_airbyte