🐛 fix: Normalization date-time should handle empty strings ""

airbyte-integrations/bases/base-normalization/Dockerfile

@@ -33,7 +33,7 @@ RUN pip install cx_Oracle
 
 COPY --from=airbyte/base-airbyte-protocol-python:0.1.1 /airbyte /airbyte
 
-# Install SSH Tunneling dependencies 
+# Install SSH Tunneling dependencies
 RUN apt-get update && apt-get install -y jq sshpass
 WORKDIR /airbyte
 COPY entrypoint.sh .
@@ -63,5 +63,5 @@ WORKDIR /airbyte
 ENV AIRBYTE_ENTRYPOINT "/airbyte/entrypoint.sh"
 ENTRYPOINT ["/airbyte/entrypoint.sh"]
 
-LABEL io.airbyte.version=0.1.51
+LABEL io.airbyte.version=0.1.52
 LABEL io.airbyte.name=airbyte/normalization

airbyte-integrations/bases/base-normalization/dbt-project-template/macros/cross_db_utils/type_conversions.sql

@@ -56,3 +56,12 @@
 {% macro sqlserver__cast_to_boolean(field) -%}
     cast({{ field }} as bit)
 {%- endmacro %}
+
+{# empty_string_to_null -------------------------------------------------     #}
+{% macro empty_string_to_null(field) -%}
+    {{ return(adapter.dispatch('empty_string_to_null')(field)) }}
+{%- endmacro %}
+
+{%- macro default__empty_string_to_null(field) -%}
+    nullif({{ field }}, '')
+{%- endmacro %}

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/bigquery/test_primary_key_streams/final/airbyte_tables/test_normalization/dedup_exchange_rate_scd.sql

@@ -31,10 +31,10 @@ select
     cast(currency as 
     string
 ) as currency,
-    cast(date as 
+    cast(nullif(date, '') as
     date
 ) as date,
-    cast(timestamp_col as 
+    cast(nullif(timestamp_col, '') as
     timestamp
 ) as timestamp_col,
     cast(HKD_special___characters as 

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/bigquery/test_primary_key_streams/final/airbyte_tables/test_normalization/exchange_rate.sql

@@ -31,10 +31,10 @@ select
     cast(currency as 
     string
 ) as currency,
-    cast(date as 
+    cast(nullif(date, '') as
     date
 ) as date,
-    cast(timestamp_col as 
+    cast(nullif(timestamp_col, '') as
     timestamp
 ) as timestamp_col,
     cast(HKD_special___characters as 

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/bigquery/test_primary_key_streams/models/generated/airbyte_ctes/test_normalization/dedup_exchange_rate_ab2.sql

@@ -3,8 +3,8 @@
 select
     cast(id as {{ dbt_utils.type_bigint() }}) as id,
     cast(currency as {{ dbt_utils.type_string() }}) as currency,
-    cast(date as {{ type_date() }}) as date,
-    cast(timestamp_col as {{ type_timestamp_with_timezone() }}) as timestamp_col,
+    cast(empty_string_to_null('date') as {{ type_date() }}) as date,
+    cast(empty_string_to_null('timestamp_col') as {{ type_timestamp_with_timezone() }}) as timestamp_col,
     cast(HKD_special___characters as {{ dbt_utils.type_float() }}) as HKD_special___characters,
     cast(HKD_special___characters_1 as {{ dbt_utils.type_string() }}) as HKD_special___characters_1,
     cast(NZD as {{ dbt_utils.type_float() }}) as NZD,

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/bigquery/test_primary_key_streams/models/generated/airbyte_ctes/test_normalization/exchange_rate_ab2.sql

@@ -3,8 +3,8 @@
 select
     cast(id as {{ dbt_utils.type_bigint() }}) as id,
     cast(currency as {{ dbt_utils.type_string() }}) as currency,
-    cast(date as {{ type_date() }}) as date,
-    cast(timestamp_col as {{ type_timestamp_with_timezone() }}) as timestamp_col,
+    cast(empty_string_to_null('date') as {{ type_date() }}) as date,
+    cast(empty_string_to_null('timestamp_col') as {{ type_timestamp_with_timezone() }}) as timestamp_col,
     cast(HKD_special___characters as {{ dbt_utils.type_float() }}) as HKD_special___characters,
     cast(HKD_special___characters_1 as {{ dbt_utils.type_string() }}) as HKD_special___characters_1,
     cast(NZD as {{ dbt_utils.type_float() }}) as NZD,

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mssql/test_primary_key_streams/final/airbyte_tables/test_normalization/dedup_exchange_rate_scd.sql

@@ -43,8 +43,8 @@ select
 ) as id,
     cast(currency as 
     VARCHAR(max)) as currency,
-    try_parse("date" as date) as "date",
-    try_parse(timestamp_col as datetime) as timestamp_col,
+    try_parse(nullif("date", '''') as date) as "date",
+    try_parse(nullif(timestamp_col, '''') as datetime) as timestamp_col,
     cast("HKD@spéçiäl & characters" as 
     float
 ) as "HKD@spéçiäl & characters",

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mssql/test_primary_key_streams/final/airbyte_tables/test_normalization/exchange_rate.sql

@@ -43,8 +43,8 @@ select
 ) as id,
     cast(currency as 
     VARCHAR(max)) as currency,
-    try_parse("date" as date) as "date",
-    try_parse(timestamp_col as datetime) as timestamp_col,
+    try_parse(nullif("date", '''') as date) as "date",
+    try_parse(nullif(timestamp_col, '''') as datetime) as timestamp_col,
     cast("HKD@spéçiäl & characters" as 
     float
 ) as "HKD@spéçiäl & characters",

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mssql/test_primary_key_streams/models/dbt_tmp_data_test/test_tmp_data_check_row_counts.sql

@@ -1,16 +1,16 @@
 with table_row_counts as (
-    select distinct count(*) as row_count, 9 as expected_count
+    select distinct count(*) as row_count, 10 as expected_count
     from {{ source('test_normalization', '_airbyte_raw_exchange_rate') }}
 union all
-    select distinct count(*) as row_count, 9 as expected_count
+    select distinct count(*) as row_count, 10 as expected_count
     from {{ ref('exchange_rate') }}
 
 union all
 
-    select distinct count(*) as row_count, 9 as expected_count
+    select distinct count(*) as row_count, 10 as expected_count
     from {{ source('test_normalization', '_airbyte_raw_dedup_exchange_rate') }}
 union all
-    select distinct count(*) as row_count, 9 as expected_count
+    select distinct count(*) as row_count, 10 as expected_count
     from {{ ref('dedup_exchange_rate_scd') }}
 union all
     select distinct count(*) as row_count, 5 as expected_count

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mssql/test_primary_key_streams/models/generated/airbyte_ctes/test_normalization/dedup_exchange_rate_ab2.sql

@@ -3,8 +3,8 @@
 select
     cast(id as {{ dbt_utils.type_bigint() }}) as id,
     cast(currency as {{ dbt_utils.type_string() }}) as currency,
-    try_parse({{ adapter.quote('date') }} as {{ type_date() }}) as {{ adapter.quote('date') }},
-    try_parse(timestamp_col as {{ type_timestamp_with_timezone() }}) as timestamp_col,
+    try_parse({{ empty_string_to_null(adapter.quote('date')) }} as {{ type_date() }}) as {{ adapter.quote('date') }},
+    try_parse({{ empty_string_to_null('timestamp_col') }} as {{ type_timestamp_with_timezone() }}) as timestamp_col,
     cast({{ adapter.quote('HKD@spéçiäl & characters') }} as {{ dbt_utils.type_float() }}) as {{ adapter.quote('HKD@spéçiäl & characters') }},
     cast(hkd_special___characters as {{ dbt_utils.type_string() }}) as hkd_special___characters,
     cast(nzd as {{ dbt_utils.type_float() }}) as nzd,

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mssql/test_primary_key_streams/models/generated/airbyte_ctes/test_normalization/exchange_rate_ab2.sql

@@ -3,8 +3,8 @@
 select
     cast(id as {{ dbt_utils.type_bigint() }}) as id,
     cast(currency as {{ dbt_utils.type_string() }}) as currency,
-    try_parse({{ adapter.quote('date') }} as {{ type_date() }}) as {{ adapter.quote('date') }},
-    try_parse(timestamp_col as {{ type_timestamp_with_timezone() }}) as timestamp_col,
+    try_parse({{ empty_string_to_null(adapter.quote('date')) }} as {{ type_date() }}) as {{ adapter.quote('date') }},
+    try_parse({{ empty_string_to_null('timestamp_col') }} as {{ type_timestamp_with_timezone() }}) as timestamp_col,
     cast({{ adapter.quote('HKD@spéçiäl & characters') }} as {{ dbt_utils.type_float() }}) as {{ adapter.quote('HKD@spéçiäl & characters') }},
     cast(hkd_special___characters as {{ dbt_utils.type_string() }}) as hkd_special___characters,
     cast(nzd as {{ dbt_utils.type_float() }}) as nzd,

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_primary_key_streams/final/airbyte_tables/test_normalization/dedup_exchange_rate_scd.sql

@@ -35,10 +35,11 @@ select
     signed
 ) as id,
     cast(currency as char) as currency,
-    cast(`date` as 
-    date
-) as `date`,
-    cast(timestamp_col as char) as timestamp_col,
+        case when `date` = '' then NULL
+        else cast(`date` as date)
+        end as `date`
+        ,
+    cast(nullif(timestamp_col, '') as char) as timestamp_col,
     cast(`HKD@spéçiäl & characters` as 
     float
 ) as `HKD@spéçiäl & characters`,

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_primary_key_streams/final/airbyte_tables/test_normalization/exchange_rate.sql

@@ -35,10 +35,11 @@ select
     signed
 ) as id,
     cast(currency as char) as currency,
-    cast(`date` as 
-    date
-) as `date`,
-    cast(timestamp_col as char) as timestamp_col,
+        case when `date` = '' then NULL
+        else cast(`date` as date)
+        end as `date`
+        ,
+    cast(nullif(timestamp_col, '') as char) as timestamp_col,
     cast(`HKD@spéçiäl & characters` as 
     float
 ) as `HKD@spéçiäl & characters`,

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_primary_key_streams/models/generated/airbyte_ctes/test_normalization/dedup_exchange_rate_ab2.sql

@@ -3,8 +3,11 @@
 select
     cast(id as {{ dbt_utils.type_bigint() }}) as id,
     cast(currency as {{ dbt_utils.type_string() }}) as currency,
-    cast({{ adapter.quote('date') }} as {{ type_date() }}) as {{ adapter.quote('date') }},
-    cast(timestamp_col as {{ type_timestamp_with_timezone() }}) as timestamp_col,
+        case when {{ adapter.quote('date') }} = '' then NULL
+        else cast({{ adapter.quote('date') }} as date)
+        end as {{ adapter.quote('date') }}
+        ,
+    cast({{ empty_string_to_null('timestamp_col') }} as {{ type_timestamp_with_timezone() }}) as timestamp_col,
     cast({{ adapter.quote('HKD@spéçiäl & characters') }} as {{ dbt_utils.type_float() }}) as {{ adapter.quote('HKD@spéçiäl & characters') }},
     cast(hkd_special___characters as {{ dbt_utils.type_string() }}) as hkd_special___characters,
     cast(nzd as {{ dbt_utils.type_float() }}) as nzd,

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_primary_key_streams/models/generated/airbyte_ctes/test_normalization/exchange_rate_ab2.sql

@@ -3,8 +3,11 @@
 select
     cast(id as {{ dbt_utils.type_bigint() }}) as id,
     cast(currency as {{ dbt_utils.type_string() }}) as currency,
-    cast({{ adapter.quote('date') }} as {{ type_date() }}) as {{ adapter.quote('date') }},
-    cast(timestamp_col as {{ type_timestamp_with_timezone() }}) as timestamp_col,
+        case when {{ adapter.quote('date') }} = '' then NULL
+        else cast({{ adapter.quote('date') }} as date)
+        end as {{ adapter.quote('date') }}
+        ,
+    cast({{ empty_string_to_null('timestamp_col') }} as {{ type_timestamp_with_timezone() }}) as timestamp_col,
     cast({{ adapter.quote('HKD@spéçiäl & characters') }} as {{ dbt_utils.type_float() }}) as {{ adapter.quote('HKD@spéçiäl & characters') }},
     cast(hkd_special___characters as {{ dbt_utils.type_string() }}) as hkd_special___characters,
     cast(nzd as {{ dbt_utils.type_float() }}) as nzd,

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/oracle/test_primary_key_streams/final/airbyte_tables/test_normalization/dedup_exchange_rate_scd.sql

@@ -27,10 +27,10 @@ select
     numeric
 ) as id,
     cast(currency as varchar2(4000)) as currency,
-    cast("DATE" as 
+    cast(nullif("DATE", '') as
     varchar2(4000)
 ) as "DATE",
-    cast(timestamp_col as 
+    cast(nullif(timestamp_col, '') as
     varchar2(4000)
 ) as timestamp_col,
     cast(hkd_special___characters as 

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/oracle/test_primary_key_streams/final/airbyte_tables/test_normalization/exchange_rate.sql

@@ -27,10 +27,10 @@ select
     numeric
 ) as id,
     cast(currency as varchar2(4000)) as currency,
-    cast("DATE" as 
+    cast(nullif("DATE", '') as
     varchar2(4000)
 ) as "DATE",
-    cast(timestamp_col as 
+    cast(nullif(timestamp_col, '') as
     varchar2(4000)
 ) as timestamp_col,
     cast(hkd_special___characters as 

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/oracle/test_primary_key_streams/models/generated/airbyte_ctes/test_normalization/dedup_exchange_rate_ab2.sql

@@ -3,8 +3,8 @@
 select
     cast(id as {{ dbt_utils.type_bigint() }}) as id,
     cast(currency as {{ dbt_utils.type_string() }}) as currency,
-    cast({{ quote('DATE') }} as {{ type_date() }}) as {{ quote('DATE') }},
-    cast(timestamp_col as {{ type_timestamp_with_timezone() }}) as timestamp_col,
+    cast(empty_string_to_null({{ quote('DATE') }}) as {{ type_date() }}) as {{ quote('DATE') }},
+    cast(empty_string_to_null('timestamp_col') as {{ type_timestamp_with_timezone() }}) as timestamp_col,
     cast(hkd_special___characters as {{ dbt_utils.type_float() }}) as hkd_special___characters,
     cast(hkd_special___characters_1 as {{ dbt_utils.type_string() }}) as hkd_special___characters_1,
     cast(nzd as {{ dbt_utils.type_float() }}) as nzd,

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/oracle/test_primary_key_streams/models/generated/airbyte_ctes/test_normalization/exchange_rate_ab2.sql

@@ -3,8 +3,8 @@
 select
     cast(id as {{ dbt_utils.type_bigint() }}) as id,
     cast(currency as {{ dbt_utils.type_string() }}) as currency,
-    cast({{ quote('DATE') }} as {{ type_date() }}) as {{ quote('DATE') }},
-    cast(timestamp_col as {{ type_timestamp_with_timezone() }}) as timestamp_col,
+    cast(empty_string_to_null({{ quote('DATE') }}) as {{ type_date() }}) as {{ quote('DATE') }},
+    cast(empty_string_to_null('timestamp_col') as {{ type_timestamp_with_timezone() }}) as timestamp_col,
     cast(hkd_special___characters as {{ dbt_utils.type_float() }}) as hkd_special___characters,
     cast(hkd_special___characters_1 as {{ dbt_utils.type_string() }}) as hkd_special___characters_1,
     cast(nzd as {{ dbt_utils.type_float() }}) as nzd,

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/postgres/test_primary_key_streams/final/airbyte_tables/test_normalization/dedup_exchange_rate_scd.sql

@@ -28,10 +28,10 @@ select
     cast(currency as 
     varchar
 ) as currency,
-    cast("date" as 
+    cast(nullif("date", '') as 
     date
 ) as "date",
-    cast(timestamp_col as 
+    cast(nullif(timestamp_col, '') as 
     timestamp with time zone
 ) as timestamp_col,
     cast("HKD@spéçiäl & characters" as 

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/postgres/test_primary_key_streams/final/airbyte_tables/test_normalization/exchange_rate.sql

@@ -28,10 +28,10 @@ select
     cast(currency as 
     varchar
 ) as currency,
-    cast("date" as 
+    cast(nullif("date", '') as 
     date
 ) as "date",
-    cast(timestamp_col as 
+    cast(nullif(timestamp_col, '') as 
     timestamp with time zone
 ) as timestamp_col,
     cast("HKD@spéçiäl & characters" as 

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/postgres/test_primary_key_streams/models/generated/airbyte_ctes/test_normalization/dedup_exchange_rate_ab2.sql

@@ -3,8 +3,8 @@
 select
     cast({{ adapter.quote('id') }} as {{ dbt_utils.type_bigint() }}) as {{ adapter.quote('id') }},
     cast(currency as {{ dbt_utils.type_string() }}) as currency,
-    cast({{ adapter.quote('date') }} as {{ type_date() }}) as {{ adapter.quote('date') }},
-    cast(timestamp_col as {{ type_timestamp_with_timezone() }}) as timestamp_col,
+    cast({{ empty_string_to_null(adapter.quote('date')) }} as {{ type_date() }}) as {{ adapter.quote('date') }},
+    cast({{ empty_string_to_null('timestamp_col') }} as {{ type_timestamp_with_timezone() }}) as timestamp_col,
     cast({{ adapter.quote('HKD@spéçiäl & characters') }} as {{ dbt_utils.type_float() }}) as {{ adapter.quote('HKD@spéçiäl & characters') }},
     cast(hkd_special___characters as {{ dbt_utils.type_string() }}) as hkd_special___characters,
     cast(nzd as {{ dbt_utils.type_float() }}) as nzd,

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/postgres/test_primary_key_streams/models/generated/airbyte_ctes/test_normalization/exchange_rate_ab2.sql

@@ -3,8 +3,8 @@
 select
     cast({{ adapter.quote('id') }} as {{ dbt_utils.type_bigint() }}) as {{ adapter.quote('id') }},
     cast(currency as {{ dbt_utils.type_string() }}) as currency,
-    cast({{ adapter.quote('date') }} as {{ type_date() }}) as {{ adapter.quote('date') }},
-    cast(timestamp_col as {{ type_timestamp_with_timezone() }}) as timestamp_col,
+    cast({{ empty_string_to_null(adapter.quote('date')) }} as {{ type_date() }}) as {{ adapter.quote('date') }},
+    cast({{ empty_string_to_null('timestamp_col') }} as {{ type_timestamp_with_timezone() }}) as timestamp_col,
     cast({{ adapter.quote('HKD@spéçiäl & characters') }} as {{ dbt_utils.type_float() }}) as {{ adapter.quote('HKD@spéçiäl & characters') }},
     cast(hkd_special___characters as {{ dbt_utils.type_string() }}) as hkd_special___characters,
     cast(nzd as {{ dbt_utils.type_float() }}) as nzd,

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/redshift/test_primary_key_streams/final/airbyte_tables/test_normalization/dedup_exchange_rate_scd.sql

@@ -29,10 +29,10 @@ select
     bigint
 ) as id,
     cast(currency as varchar) as currency,
-    cast(date as 
+    cast(nullif(date, '') as
     date
 ) as date,
-    cast(timestamp_col as 
+    cast(nullif(timestamp_col, '') as
     timestamp with time zone
 ) as timestamp_col,
     cast("hkd@spéçiäl & characters" as 

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/redshift/test_primary_key_streams/final/airbyte_tables/test_normalization/exchange_rate.sql

@@ -29,10 +29,10 @@ select
     bigint
 ) as id,
     cast(currency as varchar) as currency,
-    cast(date as 
+    cast(nullif(date, '') as
     date
 ) as date,
-    cast(timestamp_col as 
+    cast(nullif(timestamp_col, '') as
     timestamp with time zone
 ) as timestamp_col,
     cast("hkd@spéçiäl & characters" as 

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/redshift/test_primary_key_streams/models/generated/airbyte_ctes/test_normalization/dedup_exchange_rate_ab2.sql

@@ -3,8 +3,8 @@
 select
     cast(id as {{ dbt_utils.type_bigint() }}) as id,
     cast(currency as {{ dbt_utils.type_string() }}) as currency,
-    cast(date as {{ type_date() }}) as date,
-    cast(timestamp_col as {{ type_timestamp_with_timezone() }}) as timestamp_col,
+    cast(empty_string_to_null('date') as {{ type_date() }}) as date,
+    cast(empty_string_to_null('timestamp_col') as {{ type_timestamp_with_timezone() }}) as timestamp_col,
     cast({{ adapter.quote('hkd@spéçiäl & characters') }} as {{ dbt_utils.type_float() }}) as {{ adapter.quote('hkd@spéçiäl & characters') }},
     cast(hkd_special___characters as {{ dbt_utils.type_string() }}) as hkd_special___characters,
     cast(nzd as {{ dbt_utils.type_float() }}) as nzd,

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/redshift/test_primary_key_streams/models/generated/airbyte_ctes/test_normalization/exchange_rate_ab2.sql

@@ -3,8 +3,8 @@
 select
     cast(id as {{ dbt_utils.type_bigint() }}) as id,
     cast(currency as {{ dbt_utils.type_string() }}) as currency,
-    cast(date as {{ type_date() }}) as date,
-    cast(timestamp_col as {{ type_timestamp_with_timezone() }}) as timestamp_col,
+    cast(empty_string_to_null('date') as {{ type_date() }}) as date,
+    cast(empty_string_to_null('timestamp_col') as {{ type_timestamp_with_timezone() }}) as timestamp_col,
     cast({{ adapter.quote('hkd@spéçiäl & characters') }} as {{ dbt_utils.type_float() }}) as {{ adapter.quote('hkd@spéçiäl & characters') }},
     cast(hkd_special___characters as {{ dbt_utils.type_string() }}) as hkd_special___characters,
     cast(nzd as {{ dbt_utils.type_float() }}) as nzd,

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/snowflake/test_primary_key_streams/final/airbyte_tables/TEST_NORMALIZATION/DEDUP_EXCHANGE_RATE_SCD.sql

@@ -27,14 +27,15 @@ select
     cast(CURRENCY as 
     varchar
 ) as CURRENCY,
-    cast(DATE as 
+    cast(nullif(DATE, '') as 
     date
 ) as DATE,
     case
         when TIMESTAMP_COL regexp '\\d{4}-\\d{2}-\\d{2}T(\\d{2}:){2}\\d{2}(\\+|-)\\d{4}' then to_timestamp_tz(TIMESTAMP_COL, 'YYYY-MM-DDTHH24:MI:SSTZHTZM')
         when TIMESTAMP_COL regexp '\\d{4}-\\d{2}-\\d{2}T(\\d{2}:){2}\\d{2}(\\+|-)\\d{2}' then to_timestamp_tz(TIMESTAMP_COL, 'YYYY-MM-DDTHH24:MI:SSTZH')
         when TIMESTAMP_COL regexp '\\d{4}-\\d{2}-\\d{2}T(\\d{2}:){2}\\d{2}\\.\\d{1,7}(\\+|-)\\d{4}' then to_timestamp_tz(TIMESTAMP_COL, 'YYYY-MM-DDTHH24:MI:SS.FFTZHTZM')
         when TIMESTAMP_COL regexp '\\d{4}-\\d{2}-\\d{2}T(\\d{2}:){2}\\d{2}\\.\\d{1,7}(\\+|-)\\d{2}' then to_timestamp_tz(TIMESTAMP_COL, 'YYYY-MM-DDTHH24:MI:SS.FFTZH')
+        when TIMESTAMP_COL = '' then NULL
     else to_timestamp_tz(TIMESTAMP_COL)
     end as TIMESTAMP_COL
     ,

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/snowflake/test_primary_key_streams/final/airbyte_tables/TEST_NORMALIZATION/EXCHANGE_RATE.sql

@@ -27,14 +27,15 @@ select
     cast(CURRENCY as 
     varchar
 ) as CURRENCY,
-    cast(DATE as 
+    cast(nullif(DATE, '') as 
     date
 ) as DATE,
     case
         when TIMESTAMP_COL regexp '\\d{4}-\\d{2}-\\d{2}T(\\d{2}:){2}\\d{2}(\\+|-)\\d{4}' then to_timestamp_tz(TIMESTAMP_COL, 'YYYY-MM-DDTHH24:MI:SSTZHTZM')
         when TIMESTAMP_COL regexp '\\d{4}-\\d{2}-\\d{2}T(\\d{2}:){2}\\d{2}(\\+|-)\\d{2}' then to_timestamp_tz(TIMESTAMP_COL, 'YYYY-MM-DDTHH24:MI:SSTZH')
         when TIMESTAMP_COL regexp '\\d{4}-\\d{2}-\\d{2}T(\\d{2}:){2}\\d{2}\\.\\d{1,7}(\\+|-)\\d{4}' then to_timestamp_tz(TIMESTAMP_COL, 'YYYY-MM-DDTHH24:MI:SS.FFTZHTZM')
         when TIMESTAMP_COL regexp '\\d{4}-\\d{2}-\\d{2}T(\\d{2}:){2}\\d{2}\\.\\d{1,7}(\\+|-)\\d{2}' then to_timestamp_tz(TIMESTAMP_COL, 'YYYY-MM-DDTHH24:MI:SS.FFTZH')
+        when TIMESTAMP_COL = '' then NULL
     else to_timestamp_tz(TIMESTAMP_COL)
     end as TIMESTAMP_COL
     ,

airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/snowflake/test_primary_key_streams/models/generated/airbyte_ctes/TEST_NORMALIZATION/DEDUP_EXCHANGE_RATE_AB2.sql

@@ -3,12 +3,13 @@
 select
     cast(ID as {{ dbt_utils.type_bigint() }}) as ID,
     cast(CURRENCY as {{ dbt_utils.type_string() }}) as CURRENCY,
-    cast(DATE as {{ type_date() }}) as DATE,
+    cast({{ empty_string_to_null('DATE') }} as {{ type_date() }}) as DATE,
     case
         when TIMESTAMP_COL regexp '\\d{4}-\\d{2}-\\d{2}T(\\d{2}:){2}\\d{2}(\\+|-)\\d{4}' then to_timestamp_tz(TIMESTAMP_COL, 'YYYY-MM-DDTHH24:MI:SSTZHTZM')
         when TIMESTAMP_COL regexp '\\d{4}-\\d{2}-\\d{2}T(\\d{2}:){2}\\d{2}(\\+|-)\\d{2}' then to_timestamp_tz(TIMESTAMP_COL, 'YYYY-MM-DDTHH24:MI:SSTZH')
         when TIMESTAMP_COL regexp '\\d{4}-\\d{2}-\\d{2}T(\\d{2}:){2}\\d{2}\\.\\d{1,7}(\\+|-)\\d{4}' then to_timestamp_tz(TIMESTAMP_COL, 'YYYY-MM-DDTHH24:MI:SS.FFTZHTZM')
         when TIMESTAMP_COL regexp '\\d{4}-\\d{2}-\\d{2}T(\\d{2}:){2}\\d{2}\\.\\d{1,7}(\\+|-)\\d{2}' then to_timestamp_tz(TIMESTAMP_COL, 'YYYY-MM-DDTHH24:MI:SS.FFTZH')
+        when TIMESTAMP_COL = '' then NULL
     else to_timestamp_tz(TIMESTAMP_COL)
     end as TIMESTAMP_COL
     ,