Skip to content

Commit 517fc6a

Browse files
edgaoedgao
authored
Normalization: Revert to protocol v0 (#22283)
* Revert "Normalization: handle non-object top-level schemas; treat binary data as string (#22165)" This reverts commit 8276d03. * Revert "Normalization: check for ref type existence (#22161)" This reverts commit dbe56d6. * Revert "🎉Updated normalization to handle new datatypes (#19721)" This reverts commit c1d7736. * revert dest definitions * also dockerfile * re-add to changelog * add comment in dockerfile
1 parent 3e010bd commit 517fc6a

File tree

237 files changed

+1051
-4195
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

237 files changed

+1051
-4195
lines changed

‎airbyte-integrations/bases/base-normalization/Dockerfile

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,5 +28,7 @@ WORKDIR /airbyte
2828
ENV AIRBYTE_ENTRYPOINT "/airbyte/entrypoint.sh"
2929
ENTRYPOINT ["/airbyte/entrypoint.sh"]
3030

31-
LABEL io.airbyte.version=0.3.2
31+
# 0.3.x is tombstoned.
32+
# The next minor bump should go directly to 0.4.0
33+
LABEL io.airbyte.version=0.2.25
3234
LABEL io.airbyte.name=airbyte/normalization

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

Lines changed: 0 additions & 30 deletions
Original file line numberDiff line numberDiff line change
@@ -8,14 +8,6 @@
88
string
99
{% endmacro %}
1010

11-
{%- macro type_binary() -%}
12-
{{ adapter.dispatch('type_binary')() }}
13-
{%- endmacro -%}
14-
15-
{%- macro default__type_binary() -%}
16-
binary
17-
{%- endmacro -%}
18-
1911
{%- macro redshift__type_json() -%}
2012
{%- if redshift_super_type() -%}
2113
super
@@ -80,28 +72,6 @@
8072
char(1000)
8173
{%- endmacro -%}
8274

83-
{# binary data ------------------------------------------------- #}
84-
85-
{%- macro postgres__type_binary() -%}
86-
bytea
87-
{%- endmacro -%}
88-
89-
{%- macro bigquery__type_binary() -%}
90-
bytes
91-
{%- endmacro -%}
92-
93-
{%- macro mssql__type_binary() -%}
94-
VARBINARY(MAX)
95-
{%- endmacro -%}
96-
97-
{%- macro snowflake__type_binary() -%}
98-
VARBINARY
99-
{%- endmacro -%}
100-
101-
{%- macro clickhouse__type_binary() -%}
102-
VARBINARY
103-
{%- endmacro -%}
104-
10575
{# float ------------------------------------------------- #}
10676
{% macro mysql__type_float() %}
10777
float

‎airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/bigquery/test_nested_streams/models/generated/airbyte_incremental/scd/test_normalization/nested_stream_with_complex_columns_resulting_into_long_names_scd.sql

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -34,12 +34,12 @@
3434
from (
3535
select distinct _airbyte_unique_key as unique_key
3636
from {{ this }}
37-
where 1=1 {{ incremental_clause('_airbyte_normalized_at', adapter.quote(this.schema) + '.' + adapter.quote('nested_stream_with_complex_columns_resulting_into_long_names')) }}
37+
where 1=1 {{ incremental_clause('_airbyte_normalized_at', this.schema + '.' + adapter.quote('nested_stream_with_complex_columns_resulting_into_long_names')) }}
3838
) recent_records
3939
left join (
4040
select _airbyte_unique_key as unique_key, count(_airbyte_unique_key) as active_count
4141
from {{ this }}
42-
where _airbyte_active_row = 1 {{ incremental_clause('_airbyte_normalized_at', adapter.quote(this.schema) + '.' + adapter.quote('nested_stream_with_complex_columns_resulting_into_long_names')) }}
42+
where _airbyte_active_row = 1 {{ incremental_clause('_airbyte_normalized_at', this.schema + '.' + adapter.quote('nested_stream_with_complex_columns_resulting_into_long_names')) }}
4343
group by _airbyte_unique_key
4444
) active_counts
4545
on recent_records.unique_key = active_counts.unique_key

‎airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/bigquery/test_simple_streams/first_output/airbyte_tables/test_normalization/exchange_rate.sql

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@ select
2424
json_extract_scalar(_airbyte_data, "$['datetime_no_tz']") as datetime_no_tz,
2525
json_extract_scalar(_airbyte_data, "$['time_tz']") as time_tz,
2626
json_extract_scalar(_airbyte_data, "$['time_no_tz']") as time_no_tz,
27-
json_extract_scalar(_airbyte_data, "$['property_binary_data']") as property_binary_data,
2827
_airbyte_ab_id,
2928
_airbyte_emitted_at,
3029
CURRENT_TIMESTAMP() as _airbyte_normalized_at
@@ -75,7 +74,6 @@ select
7574
cast(nullif(time_no_tz, '') as
7675
time
7776
) as time_no_tz,
78-
cast(FROM_BASE64(property_binary_data) as bytes) as property_binary_data,
7977
_airbyte_ab_id,
8078
_airbyte_emitted_at,
8179
CURRENT_TIMESTAMP() as _airbyte_normalized_at
@@ -113,8 +111,6 @@ select
113111
string
114112
), ''), '-', coalesce(cast(time_no_tz as
115113
string
116-
), ''), '-', coalesce(cast(property_binary_data as
117-
string
118114
), '')) as
119115
string
120116
))) as _airbyte_exchange_rate_hashid,
@@ -138,7 +134,6 @@ select
138134
datetime_no_tz,
139135
time_tz,
140136
time_no_tz,
141-
property_binary_data,
142137
_airbyte_ab_id,
143138
_airbyte_emitted_at,
144139
CURRENT_TIMESTAMP() as _airbyte_normalized_at,

‎airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/bigquery/test_simple_streams/models/generated/airbyte_incremental/scd/test_normalization/dedup_exchange_rate_scd.sql

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -34,12 +34,12 @@
3434
from (
3535
select distinct _airbyte_unique_key as unique_key
3636
from {{ this }}
37-
where 1=1 {{ incremental_clause('_airbyte_normalized_at', adapter.quote(this.schema) + '.' + adapter.quote('dedup_exchange_rate')) }}
37+
where 1=1 {{ incremental_clause('_airbyte_normalized_at', this.schema + '.' + adapter.quote('dedup_exchange_rate')) }}
3838
) recent_records
3939
left join (
4040
select _airbyte_unique_key as unique_key, count(_airbyte_unique_key) as active_count
4141
from {{ this }}
42-
where _airbyte_active_row = 1 {{ incremental_clause('_airbyte_normalized_at', adapter.quote(this.schema) + '.' + adapter.quote('dedup_exchange_rate')) }}
42+
where _airbyte_active_row = 1 {{ incremental_clause('_airbyte_normalized_at', this.schema + '.' + adapter.quote('dedup_exchange_rate')) }}
4343
group by _airbyte_unique_key
4444
) active_counts
4545
on recent_records.unique_key = active_counts.unique_key

‎airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/bigquery/test_simple_streams/models/generated/airbyte_tables/test_normalization/exchange_rate.sql

Lines changed: 0 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -3,22 +3,6 @@
33
partition_by = {"field": "_airbyte_emitted_at", "data_type": "timestamp", "granularity": "day"},
44
unique_key = '_airbyte_ab_id',
55
schema = "test_normalization",
6-
post_hook = ["
7-
{%
8-
set scd_table_relation = adapter.get_relation(
9-
database=this.database,
10-
schema=this.schema,
11-
identifier='exchange_rate_scd'
12-
)
13-
%}
14-
{%
15-
if scd_table_relation is not none
16-
%}
17-
{%
18-
do adapter.drop_relation(scd_table_relation)
19-
%}
20-
{% endif %}
21-
"],
226
tags = [ "top-level" ]
237
) }}
248
-- Final base SQL model
@@ -37,7 +21,6 @@ select
3721
datetime_no_tz,
3822
time_tz,
3923
time_no_tz,
40-
property_binary_data,
4124
_airbyte_ab_id,
4225
_airbyte_emitted_at,
4326
{{ current_timestamp() }} as _airbyte_normalized_at,

‎airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/bigquery/test_simple_streams/modified_models/generated/airbyte_incremental/scd/test_normalization/dedup_exchange_rate_scd.sql

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -34,12 +34,12 @@
3434
from (
3535
select distinct _airbyte_unique_key as unique_key
3636
from {{ this }}
37-
where 1=1 {{ incremental_clause('_airbyte_normalized_at', adapter.quote(this.schema) + '.' + adapter.quote('dedup_exchange_rate')) }}
37+
where 1=1 {{ incremental_clause('_airbyte_normalized_at', this.schema + '.' + adapter.quote('dedup_exchange_rate')) }}
3838
) recent_records
3939
left join (
4040
select _airbyte_unique_key as unique_key, count(_airbyte_unique_key) as active_count
4141
from {{ this }}
42-
where _airbyte_active_row = 1 {{ incremental_clause('_airbyte_normalized_at', adapter.quote(this.schema) + '.' + adapter.quote('dedup_exchange_rate')) }}
42+
where _airbyte_active_row = 1 {{ incremental_clause('_airbyte_normalized_at', this.schema + '.' + adapter.quote('dedup_exchange_rate')) }}
4343
group by _airbyte_unique_key
4444
) active_counts
4545
on recent_records.unique_key = active_counts.unique_key

‎airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/bigquery/test_simple_streams/modified_models/generated/airbyte_tables/test_normalization/exchange_rate.sql

Lines changed: 0 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -3,22 +3,6 @@
33
partition_by = {"field": "_airbyte_emitted_at", "data_type": "timestamp", "granularity": "day"},
44
unique_key = '_airbyte_ab_id',
55
schema = "test_normalization",
6-
post_hook = ["
7-
{%
8-
set scd_table_relation = adapter.get_relation(
9-
database=this.database,
10-
schema=this.schema,
11-
identifier='exchange_rate_scd'
12-
)
13-
%}
14-
{%
15-
if scd_table_relation is not none
16-
%}
17-
{%
18-
do adapter.drop_relation(scd_table_relation)
19-
%}
20-
{% endif %}
21-
"],
226
tags = [ "top-level" ]
237
) }}
248
-- Final base SQL model

‎airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/bigquery/test_simple_streams/second_output/airbyte_tables/test_normalization/exchange_rate.sql

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@ select
2424
json_extract_scalar(_airbyte_data, "$['datetime_no_tz']") as datetime_no_tz,
2525
json_extract_scalar(_airbyte_data, "$['time_tz']") as time_tz,
2626
json_extract_scalar(_airbyte_data, "$['time_no_tz']") as time_no_tz,
27-
json_extract_scalar(_airbyte_data, "$['property_binary_data']") as property_binary_data,
2827
_airbyte_ab_id,
2928
_airbyte_emitted_at,
3029
CURRENT_TIMESTAMP() as _airbyte_normalized_at
@@ -75,7 +74,6 @@ select
7574
cast(nullif(time_no_tz, '') as
7675
time
7776
) as time_no_tz,
78-
cast(FROM_BASE64(property_binary_data) as bytes) as property_binary_data,
7977
_airbyte_ab_id,
8078
_airbyte_emitted_at,
8179
CURRENT_TIMESTAMP() as _airbyte_normalized_at
@@ -113,8 +111,6 @@ select
113111
string
114112
), ''), '-', coalesce(cast(time_no_tz as
115113
string
116-
), ''), '-', coalesce(cast(property_binary_data as
117-
string
118114
), '')) as
119115
string
120116
))) as _airbyte_exchange_rate_hashid,
@@ -138,7 +134,6 @@ select
138134
datetime_no_tz,
139135
time_tz,
140136
time_no_tz,
141-
property_binary_data,
142137
_airbyte_ab_id,
143138
_airbyte_emitted_at,
144139
CURRENT_TIMESTAMP() as _airbyte_normalized_at,

‎airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/clickhouse/test_simple_streams/first_output/airbyte_ctes/test_normalization/dedup_exchange_rate_ab1.sql

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11

22

3-
create view _airbyte_test_normalization.dedup_exchange_rate_ab1
3+
create view _airbyte_test_normalization.dedup_exchange_rate_ab1__dbt_tmp
44

55
as (
66

‎airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/clickhouse/test_simple_streams/first_output/airbyte_ctes/test_normalization/dedup_exchange_rate_ab2.sql

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,26 +1,26 @@
11

22

3-
create view _airbyte_test_normalization.dedup_exchange_rate_ab2
3+
create view _airbyte_test_normalization.dedup_exchange_rate_ab2__dbt_tmp
44

55
as (
66

77
-- SQL model to cast each column to its adequate SQL type converted from the JSON schema type
88
-- depends_on: _airbyte_test_normalization.dedup_exchange_rate_ab1
99
select
10-
accurateCastOrNull(trim(BOTH '"' from id), '
10+
accurateCastOrNull(id, '
1111
BIGINT
1212
') as id,
1313
nullif(accurateCastOrNull(trim(BOTH '"' from currency), 'String'), 'null') as currency,
1414
toDate(parseDateTimeBestEffortOrNull(trim(BOTH '"' from nullif(date, '')))) as date,
1515
parseDateTime64BestEffortOrNull(trim(BOTH '"' from nullif(timestamp_col, ''))) as timestamp_col,
16-
accurateCastOrNull(trim(BOTH '"' from "HKD@spéçiäl & characters"), '
16+
accurateCastOrNull("HKD@spéçiäl & characters", '
1717
Float64
1818
') as "HKD@spéçiäl & characters",
1919
nullif(accurateCastOrNull(trim(BOTH '"' from HKD_special___characters), 'String'), 'null') as HKD_special___characters,
20-
accurateCastOrNull(trim(BOTH '"' from NZD), '
20+
accurateCastOrNull(NZD, '
2121
Float64
2222
') as NZD,
23-
accurateCastOrNull(trim(BOTH '"' from USD), '
23+
accurateCastOrNull(USD, '
2424
Float64
2525
') as USD,
2626
_airbyte_ab_id,

‎airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/clickhouse/test_simple_streams/first_output/airbyte_incremental/scd/test_normalization/dedup_cdc_excluded_scd.sql

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,5 @@
11

2-
3-
4-
2+
53

64

75
insert into test_normalization.dedup_cdc_excluded_scd ("_airbyte_unique_key", "_airbyte_unique_key_scd", "id", "name", "_ab_cdc_lsn", "_ab_cdc_updated_at", "_ab_cdc_deleted_at", "_airbyte_start_at", "_airbyte_end_at", "_airbyte_active_row", "_airbyte_ab_id", "_airbyte_emitted_at", "_airbyte_normalized_at", "_airbyte_dedup_cdc_excluded_hashid")
@@ -103,4 +101,4 @@ select
103101
_airbyte_dedup_cdc_excluded_hashid
104102
from dedup_data where _airbyte_row_num = 1
105103

106-
104+

‎airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/clickhouse/test_simple_streams/first_output/airbyte_incremental/scd/test_normalization/dedup_exchange_rate_scd.sql

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,5 @@
11

2-
3-
4-
2+
53

64

75
insert into test_normalization.dedup_exchange_rate_scd ("_airbyte_unique_key", "_airbyte_unique_key_scd", "id", "currency", "date", "timestamp_col", "HKD@spéçiäl & characters", "HKD_special___characters", "NZD", "USD", "_airbyte_start_at", "_airbyte_end_at", "_airbyte_active_row", "_airbyte_ab_id", "_airbyte_emitted_at", "_airbyte_normalized_at", "_airbyte_dedup_exchange_rate_hashid")
@@ -107,4 +105,4 @@ select
107105
_airbyte_dedup_exchange_rate_hashid
108106
from dedup_data where _airbyte_row_num = 1
109107

110-
108+

‎airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/clickhouse/test_simple_streams/first_output/airbyte_incremental/scd/test_normalization/renamed_dedup_cdc_excluded_scd.sql

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,5 @@
11

2-
3-
4-
2+
53

64

75
insert into test_normalization.renamed_dedup_cdc_excluded_scd ("_airbyte_unique_key", "_airbyte_unique_key_scd", "id", "_ab_cdc_updated_at", "_airbyte_start_at", "_airbyte_end_at", "_airbyte_active_row", "_airbyte_ab_id", "_airbyte_emitted_at", "_airbyte_normalized_at", "_airbyte_renamed_dedup_cdc_excluded_hashid")
@@ -89,4 +87,4 @@ select
8987
_airbyte_renamed_dedup_cdc_excluded_hashid
9088
from dedup_data where _airbyte_row_num = 1
9189

92-
90+

‎airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/clickhouse/test_simple_streams/first_output/airbyte_incremental/test_normalization/dedup_exchange_rate.sql

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,5 @@
11

2-
3-
4-
2+
53

64

75
insert into test_normalization.dedup_exchange_rate ("_airbyte_unique_key", "id", "currency", "date", "timestamp_col", "HKD@spéçiäl & characters", "HKD_special___characters", "NZD", "USD", "_airbyte_ab_id", "_airbyte_emitted_at", "_airbyte_normalized_at", "_airbyte_dedup_exchange_rate_hashid")
@@ -28,4 +26,4 @@ where 1 = 1
2826
and _airbyte_active_row = 1
2927

3028

31-
29+

‎airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/clickhouse/test_simple_streams/first_output/airbyte_incremental/test_normalization/renamed_dedup_cdc_excluded.sql

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,5 @@
11

2-
3-
4-
2+
53

64

75
insert into test_normalization.renamed_dedup_cdc_excluded ("_airbyte_unique_key", "id", "_ab_cdc_updated_at", "_airbyte_ab_id", "_airbyte_emitted_at", "_airbyte_normalized_at", "_airbyte_renamed_dedup_cdc_excluded_hashid")
@@ -22,4 +20,4 @@ where 1 = 1
2220
and _airbyte_active_row = 1
2321

2422

25-
23+

‎airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/clickhouse/test_simple_streams/first_output/airbyte_tables/test_normalization/exchange_rate.sql

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,7 @@
11

2-
3-
42

53

6-
insert into test_normalization.exchange_rate ("id", "currency", "date", "timestamp_col", "HKD@spéçiäl & characters", "HKD_special___characters", "NZD", "USD", "column___with__quotes", "datetime_tz", "datetime_no_tz", "time_tz", "time_no_tz", "property_binary_data", "_airbyte_ab_id", "_airbyte_emitted_at", "_airbyte_normalized_at", "_airbyte_exchange_rate_hashid")
4+
insert into test_normalization.exchange_rate__dbt_tmp ("id", "currency", "date", "timestamp_col", "HKD@spéçiäl & characters", "HKD_special___characters", "NZD", "USD", "column___with__quotes", "datetime_tz", "datetime_no_tz", "time_tz", "time_no_tz", "_airbyte_ab_id", "_airbyte_emitted_at", "_airbyte_normalized_at", "_airbyte_exchange_rate_hashid")
75

86
-- Final base SQL model
97
-- depends_on: _airbyte_test_normalization.exchange_rate_ab3
@@ -21,7 +19,6 @@ select
2119
datetime_no_tz,
2220
time_tz,
2321
time_no_tz,
24-
property_binary_data,
2522
_airbyte_ab_id,
2623
_airbyte_emitted_at,
2724
now() as _airbyte_normalized_at,

‎airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/clickhouse/test_simple_streams/first_output/airbyte_views/test_normalization/dedup_exchange_rate_stg.sql

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11

22

3-
create view _airbyte_test_normalization.dedup_exchange_rate_stg
3+
create view _airbyte_test_normalization.dedup_exchange_rate_stg__dbt_tmp
44

55
as (
66

‎airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/clickhouse/test_simple_streams/first_output/airbyte_views/test_normalization/multiple_column_names_conflicts_stg.sql

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11

22

3-
create view _airbyte_test_normalization.multiple_column_names_conflicts_stg
3+
create view _airbyte_test_normalization.multiple_column_names_conflicts_stg__dbt_tmp
44

55
as (
66

‎airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/clickhouse/test_simple_streams/models/generated/airbyte_ctes/test_normalization/dedup_exchange_rate_ab2.sql

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -6,14 +6,14 @@
66
-- SQL model to cast each column to its adequate SQL type converted from the JSON schema type
77
-- depends_on: {{ ref('dedup_exchange_rate_ab1') }}
88
select
9-
accurateCastOrNull(trim(BOTH '"' from id), '{{ dbt_utils.type_bigint() }}') as id,
9+
accurateCastOrNull(id, '{{ dbt_utils.type_bigint() }}') as id,
1010
nullif(accurateCastOrNull(trim(BOTH '"' from currency), '{{ dbt_utils.type_string() }}'), 'null') as currency,
1111
toDate(parseDateTimeBestEffortOrNull(trim(BOTH '"' from {{ empty_string_to_null('date') }}))) as date,
1212
parseDateTime64BestEffortOrNull(trim(BOTH '"' from {{ empty_string_to_null('timestamp_col') }})) as timestamp_col,
13-
accurateCastOrNull(trim(BOTH '"' from {{ quote('HKD@spéçiäl & characters') }}), '{{ dbt_utils.type_float() }}') as {{ quote('HKD@spéçiäl & characters') }},
13+
accurateCastOrNull({{ quote('HKD@spéçiäl & characters') }}, '{{ dbt_utils.type_float() }}') as {{ quote('HKD@spéçiäl & characters') }},
1414
nullif(accurateCastOrNull(trim(BOTH '"' from HKD_special___characters), '{{ dbt_utils.type_string() }}'), 'null') as HKD_special___characters,
15-
accurateCastOrNull(trim(BOTH '"' from NZD), '{{ dbt_utils.type_float() }}') as NZD,
16-
accurateCastOrNull(trim(BOTH '"' from USD), '{{ dbt_utils.type_float() }}') as USD,
15+
accurateCastOrNull(NZD, '{{ dbt_utils.type_float() }}') as NZD,
16+
accurateCastOrNull(USD, '{{ dbt_utils.type_float() }}') as USD,
1717
_airbyte_ab_id,
1818
_airbyte_emitted_at,
1919
{{ current_timestamp() }} as _airbyte_normalized_at

0 commit comments

Comments
 (0)