From 4cfbf446159e03c967aca98ca0e1ba6df3014d71 Mon Sep 17 00:00:00 2001 From: Christophe Duong Date: Thu, 3 Mar 2022 17:23:08 +0100 Subject: [PATCH 1/2] Regenerate MySQL outputs from normalization tests --- .../nested_stream_with_co___names_partition_data.sql | 2 +- .../nested_stream_with_co__ion_double_array_data.sql | 2 +- .../nested_stream_with_co_1g_into_long_names_ab2.sql | 4 ++-- .../nested_stream_with_co___names_partition_data.sql | 2 +- .../nested_stream_with_co__ion_double_array_data.sql | 2 +- .../airbyte_tables/test_normalization/exchange_rate.sql | 8 ++++---- .../test_normalization/dedup_exchange_rate_stg.sql | 6 +++--- .../multiple_column_names_conflicts_stg.sql | 4 ++-- .../test_normalization/dedup_exchange_rate_ab2.sql | 6 +++--- .../airbyte_tables/test_normalization/exchange_rate.sql | 8 ++++---- .../test_normalization/dedup_exchange_rate_stg.sql | 6 +++--- 11 files changed, 25 insertions(+), 25 deletions(-) diff --git a/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_nested_streams/first_output/airbyte_incremental/test_normalization/nested_stream_with_co___names_partition_data.sql b/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_nested_streams/first_output/airbyte_incremental/test_normalization/nested_stream_with_co___names_partition_data.sql index 1b863065bb28..eea4c0c44827 100644 --- a/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_nested_streams/first_output/airbyte_incremental/test_normalization/nested_stream_with_co___names_partition_data.sql +++ b/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_nested_streams/first_output/airbyte_incremental/test_normalization/nested_stream_with_co___names_partition_data.sql @@ -74,7 +74,7 @@ and `DATA` is not null -- depends_on: __dbt__CTE__nested_stream_with_co_3es_partition_data_ab1 select _airbyte_partition_hashid, - cast(currency as char) as currency, + cast(currency as char(1024)) as currency, _airbyte_ab_id, _airbyte_emitted_at, diff --git a/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_nested_streams/first_output/airbyte_incremental/test_normalization/nested_stream_with_co__ion_double_array_data.sql b/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_nested_streams/first_output/airbyte_incremental/test_normalization/nested_stream_with_co__ion_double_array_data.sql index 38177a0ee51a..8819c2350a9a 100644 --- a/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_nested_streams/first_output/airbyte_incremental/test_normalization/nested_stream_with_co__ion_double_array_data.sql +++ b/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_nested_streams/first_output/airbyte_incremental/test_normalization/nested_stream_with_co__ion_double_array_data.sql @@ -74,7 +74,7 @@ and double_array_data is not null -- depends_on: __dbt__CTE__nested_stream_with_co_3double_array_data_ab1 select _airbyte_partition_hashid, - cast(id as char) as id, + cast(id as char(1024)) as id, _airbyte_ab_id, _airbyte_emitted_at, diff --git a/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_nested_streams/models/generated/airbyte_ctes/test_normalization/nested_stream_with_co_1g_into_long_names_ab2.sql b/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_nested_streams/models/generated/airbyte_ctes/test_normalization/nested_stream_with_co_1g_into_long_names_ab2.sql index cad7e05cca2c..6f090707a2ba 100644 --- a/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_nested_streams/models/generated/airbyte_ctes/test_normalization/nested_stream_with_co_1g_into_long_names_ab2.sql +++ b/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_nested_streams/models/generated/airbyte_ctes/test_normalization/nested_stream_with_co_1g_into_long_names_ab2.sql @@ -6,8 +6,8 @@ -- SQL model to cast each column to its adequate SQL type converted from the JSON schema type -- depends_on: {{ ref('nested_stream_with_co_1g_into_long_names_ab1') }} select - cast(id as {{ dbt_utils.type_string() }}) as id, - cast({{ adapter.quote('date') }} as {{ dbt_utils.type_string() }}) as {{ adapter.quote('date') }}, + cast(id as {{ dbt_utils.type_string() }}(1024)) as id, + cast({{ adapter.quote('date') }} as {{ dbt_utils.type_string() }}(1024)) as {{ adapter.quote('date') }}, cast({{ adapter.quote('partition') }} as {{ type_json() }}) as {{ adapter.quote('partition') }}, _airbyte_ab_id, _airbyte_emitted_at, diff --git a/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_nested_streams/second_output/airbyte_incremental/test_normalization/nested_stream_with_co___names_partition_data.sql b/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_nested_streams/second_output/airbyte_incremental/test_normalization/nested_stream_with_co___names_partition_data.sql index 1b863065bb28..eea4c0c44827 100644 --- a/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_nested_streams/second_output/airbyte_incremental/test_normalization/nested_stream_with_co___names_partition_data.sql +++ b/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_nested_streams/second_output/airbyte_incremental/test_normalization/nested_stream_with_co___names_partition_data.sql @@ -74,7 +74,7 @@ and `DATA` is not null -- depends_on: __dbt__CTE__nested_stream_with_co_3es_partition_data_ab1 select _airbyte_partition_hashid, - cast(currency as char) as currency, + cast(currency as char(1024)) as currency, _airbyte_ab_id, _airbyte_emitted_at, diff --git a/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_nested_streams/second_output/airbyte_incremental/test_normalization/nested_stream_with_co__ion_double_array_data.sql b/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_nested_streams/second_output/airbyte_incremental/test_normalization/nested_stream_with_co__ion_double_array_data.sql index 38177a0ee51a..8819c2350a9a 100644 --- a/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_nested_streams/second_output/airbyte_incremental/test_normalization/nested_stream_with_co__ion_double_array_data.sql +++ b/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_nested_streams/second_output/airbyte_incremental/test_normalization/nested_stream_with_co__ion_double_array_data.sql @@ -74,7 +74,7 @@ and double_array_data is not null -- depends_on: __dbt__CTE__nested_stream_with_co_3double_array_data_ab1 select _airbyte_partition_hashid, - cast(id as char) as id, + cast(id as char(1024)) as id, _airbyte_ab_id, _airbyte_emitted_at, diff --git a/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_simple_streams/first_output/airbyte_tables/test_normalization/exchange_rate.sql b/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_simple_streams/first_output/airbyte_tables/test_normalization/exchange_rate.sql index 1bd37b2c3516..0ee59f50d8e7 100644 --- a/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_simple_streams/first_output/airbyte_tables/test_normalization/exchange_rate.sql +++ b/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_simple_streams/first_output/airbyte_tables/test_normalization/exchange_rate.sql @@ -43,23 +43,23 @@ select cast(id as signed ) as id, - cast(currency as char) as currency, + cast(currency as char(1024)) as currency, case when `date` = '' then NULL else cast(`date` as date) end as `date` , - cast(nullif(timestamp_col, '') as char) as timestamp_col, + cast(nullif(timestamp_col, '') as char(1024)) as timestamp_col, cast(`HKD@spéçiäl & characters` as float ) as `HKD@spéçiäl & characters`, - cast(hkd_special___characters as char) as hkd_special___characters, + cast(hkd_special___characters as char(1024)) as hkd_special___characters, cast(nzd as float ) as nzd, cast(usd as float ) as usd, - cast(`column__'with"_quotes` as char) as `column__'with"_quotes`, + cast(`column__'with"_quotes` as char(1024)) as `column__'with"_quotes`, _airbyte_ab_id, _airbyte_emitted_at, diff --git a/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_simple_streams/first_output/airbyte_views/test_normalization/dedup_exchange_rate_stg.sql b/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_simple_streams/first_output/airbyte_views/test_normalization/dedup_exchange_rate_stg.sql index 0a40b13c0763..00d7e578d293 100644 --- a/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_simple_streams/first_output/airbyte_views/test_normalization/dedup_exchange_rate_stg.sql +++ b/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_simple_streams/first_output/airbyte_views/test_normalization/dedup_exchange_rate_stg.sql @@ -39,16 +39,16 @@ select cast(id as signed ) as id, - cast(currency as char) as currency, + cast(currency as char(1024)) as currency, case when `date` = '' then NULL else cast(`date` as date) end as `date` , - cast(nullif(timestamp_col, '') as char) as timestamp_col, + cast(nullif(timestamp_col, '') as char(1024)) as timestamp_col, cast(`HKD@spéçiäl & characters` as float ) as `HKD@spéçiäl & characters`, - cast(hkd_special___characters as char) as hkd_special___characters, + cast(hkd_special___characters as char(1024)) as hkd_special___characters, cast(nzd as float ) as nzd, diff --git a/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_simple_streams/first_output/airbyte_views/test_normalization/multiple_column_names_conflicts_stg.sql b/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_simple_streams/first_output/airbyte_views/test_normalization/multiple_column_names_conflicts_stg.sql index ba1ab0216540..55de2948c5ef 100644 --- a/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_simple_streams/first_output/airbyte_views/test_normalization/multiple_column_names_conflicts_stg.sql +++ b/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_simple_streams/first_output/airbyte_views/test_normalization/multiple_column_names_conflicts_stg.sql @@ -37,7 +37,7 @@ select cast(id as signed ) as id, - cast(`User Id` as char) as `User Id`, + cast(`User Id` as char(1024)) as `User Id`, cast(user_id as float ) as user_id, @@ -47,7 +47,7 @@ select cast(`user id_2` as float ) as `user id_2`, - cast(`User@Id` as char) as `User@Id`, + cast(`User@Id` as char(1024)) as `User@Id`, cast(userid as float ) as userid, diff --git a/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_simple_streams/models/generated/airbyte_ctes/test_normalization/dedup_exchange_rate_ab2.sql b/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_simple_streams/models/generated/airbyte_ctes/test_normalization/dedup_exchange_rate_ab2.sql index 5e294567f760..ca93b9a8d536 100644 --- a/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_simple_streams/models/generated/airbyte_ctes/test_normalization/dedup_exchange_rate_ab2.sql +++ b/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_simple_streams/models/generated/airbyte_ctes/test_normalization/dedup_exchange_rate_ab2.sql @@ -7,14 +7,14 @@ -- depends_on: {{ ref('dedup_exchange_rate_ab1') }} select cast(id as {{ dbt_utils.type_bigint() }}) as id, - cast(currency as {{ dbt_utils.type_string() }}) as currency, + cast(currency as {{ dbt_utils.type_string() }}(1024)) as currency, 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({{ empty_string_to_null('timestamp_col') }} as {{ type_timestamp_with_timezone() }}(1024)) 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(hkd_special___characters as {{ dbt_utils.type_string() }}(1024)) as hkd_special___characters, cast(nzd as {{ dbt_utils.type_float() }}) as nzd, cast(usd as {{ dbt_utils.type_float() }}) as usd, _airbyte_ab_id, diff --git a/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_simple_streams/second_output/airbyte_tables/test_normalization/exchange_rate.sql b/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_simple_streams/second_output/airbyte_tables/test_normalization/exchange_rate.sql index 1bd37b2c3516..0ee59f50d8e7 100644 --- a/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_simple_streams/second_output/airbyte_tables/test_normalization/exchange_rate.sql +++ b/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_simple_streams/second_output/airbyte_tables/test_normalization/exchange_rate.sql @@ -43,23 +43,23 @@ select cast(id as signed ) as id, - cast(currency as char) as currency, + cast(currency as char(1024)) as currency, case when `date` = '' then NULL else cast(`date` as date) end as `date` , - cast(nullif(timestamp_col, '') as char) as timestamp_col, + cast(nullif(timestamp_col, '') as char(1024)) as timestamp_col, cast(`HKD@spéçiäl & characters` as float ) as `HKD@spéçiäl & characters`, - cast(hkd_special___characters as char) as hkd_special___characters, + cast(hkd_special___characters as char(1024)) as hkd_special___characters, cast(nzd as float ) as nzd, cast(usd as float ) as usd, - cast(`column__'with"_quotes` as char) as `column__'with"_quotes`, + cast(`column__'with"_quotes` as char(1024)) as `column__'with"_quotes`, _airbyte_ab_id, _airbyte_emitted_at, diff --git a/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_simple_streams/second_output/airbyte_views/test_normalization/dedup_exchange_rate_stg.sql b/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_simple_streams/second_output/airbyte_views/test_normalization/dedup_exchange_rate_stg.sql index 0a40b13c0763..00d7e578d293 100644 --- a/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_simple_streams/second_output/airbyte_views/test_normalization/dedup_exchange_rate_stg.sql +++ b/airbyte-integrations/bases/base-normalization/integration_tests/normalization_test_output/mysql/test_simple_streams/second_output/airbyte_views/test_normalization/dedup_exchange_rate_stg.sql @@ -39,16 +39,16 @@ select cast(id as signed ) as id, - cast(currency as char) as currency, + cast(currency as char(1024)) as currency, case when `date` = '' then NULL else cast(`date` as date) end as `date` , - cast(nullif(timestamp_col, '') as char) as timestamp_col, + cast(nullif(timestamp_col, '') as char(1024)) as timestamp_col, cast(`HKD@spéçiäl & characters` as float ) as `HKD@spéçiäl & characters`, - cast(hkd_special___characters as char) as hkd_special___characters, + cast(hkd_special___characters as char(1024)) as hkd_special___characters, cast(nzd as float ) as nzd, From 2683d66718124f904f97ae57c6b79e0229de9226 Mon Sep 17 00:00:00 2001 From: Christophe Duong Date: Thu, 3 Mar 2022 17:26:52 +0100 Subject: [PATCH 2/2] format --- .../src/test/resources/expected_spec.json | 33 ++++--------------- .../src/main/resources/spec.json | 5 +-- .../destination.py | 12 ++----- .../setup.py | 4 +-- .../src/main/resources/spec.json | 5 ++- .../source_chargebee/schemas/credit_note.json | 9 +++-- .../schemas/customer_count.json | 18 +++++----- .../sources/SnowflakeSourceDatatypeTest.java | 3 +- .../schemas/shared/meta_data.json | 30 ++++++++--------- 9 files changed, 48 insertions(+), 71 deletions(-) diff --git a/airbyte-integrations/connectors/destination-clickhouse-strict-encrypt/src/test/resources/expected_spec.json b/airbyte-integrations/connectors/destination-clickhouse-strict-encrypt/src/test/resources/expected_spec.json index d27dea83a7f4..1a1160784109 100644 --- a/airbyte-integrations/connectors/destination-clickhouse-strict-encrypt/src/test/resources/expected_spec.json +++ b/airbyte-integrations/connectors/destination-clickhouse-strict-encrypt/src/test/resources/expected_spec.json @@ -3,21 +3,12 @@ "supportsIncremental": true, "supportsNormalization": true, "supportsDBT": false, - "supported_destination_sync_modes": [ - "overwrite", - "append", - "append_dedup" - ], + "supported_destination_sync_modes": ["overwrite", "append", "append_dedup"], "connectionSpecification": { "$schema": "http://json-schema.org/draft-07/schema#", "title": "ClickHouse Destination Spec", "type": "object", - "required": [ - "host", - "port", - "database", - "username" - ], + "required": ["host", "port", "database", "username"], "additionalProperties": true, "properties": { "host": { @@ -33,9 +24,7 @@ "minimum": 0, "maximum": 65536, "default": 8123, - "examples": [ - "8123" - ], + "examples": ["8123"], "order": 1 }, "tcp-port": { @@ -45,9 +34,7 @@ "minimum": 0, "maximum": 65536, "default": 9000, - "examples": [ - "9000" - ], + "examples": ["9000"], "order": 2 }, "database": { @@ -76,9 +63,7 @@ "oneOf": [ { "title": "No Tunnel", - "required": [ - "tunnel_method" - ], + "required": ["tunnel_method"], "properties": { "tunnel_method": { "description": "No ssh tunnel needed to connect to database", @@ -117,9 +102,7 @@ "minimum": 0, "maximum": 65536, "default": 22, - "examples": [ - "22" - ], + "examples": ["22"], "order": 2 }, "tunnel_user": { @@ -167,9 +150,7 @@ "minimum": 0, "maximum": 65536, "default": 22, - "examples": [ - "22" - ], + "examples": ["22"], "order": 2 }, "tunnel_user": { diff --git a/airbyte-integrations/connectors/destination-oracle/src/main/resources/spec.json b/airbyte-integrations/connectors/destination-oracle/src/main/resources/spec.json index 9422b0958de9..a8343691a3ae 100644 --- a/airbyte-integrations/connectors/destination-oracle/src/main/resources/spec.json +++ b/airbyte-integrations/connectors/destination-oracle/src/main/resources/spec.json @@ -3,10 +3,7 @@ "supportsIncremental": true, "supportsNormalization": false, "supportsDBT": false, - "supported_destination_sync_modes": [ - "overwrite", - "append" - ], + "supported_destination_sync_modes": ["overwrite", "append"], "connectionSpecification": { "$schema": "http://json-schema.org/draft-07/schema#", "title": "Oracle Destination Spec", diff --git a/airbyte-integrations/connectors/destination-scaffold-destination-python/destination_scaffold_destination_python/destination.py b/airbyte-integrations/connectors/destination-scaffold-destination-python/destination_scaffold_destination_python/destination.py index 276f9861bbd3..0705ec76e081 100644 --- a/airbyte-integrations/connectors/destination-scaffold-destination-python/destination_scaffold_destination_python/destination.py +++ b/airbyte-integrations/connectors/destination-scaffold-destination-python/destination_scaffold_destination_python/destination.py @@ -3,19 +3,16 @@ # -from typing import Mapping, Any, Iterable +from typing import Any, Iterable, Mapping from airbyte_cdk import AirbyteLogger from airbyte_cdk.destinations import Destination -from airbyte_cdk.models import AirbyteConnectionStatus, ConfiguredAirbyteCatalog, AirbyteMessage, Status +from airbyte_cdk.models import AirbyteConnectionStatus, AirbyteMessage, ConfiguredAirbyteCatalog, Status class DestinationScaffoldDestinationPython(Destination): def write( - self, - config: Mapping[str, Any], - configured_catalog: ConfiguredAirbyteCatalog, - input_messages: Iterable[AirbyteMessage] + self, config: Mapping[str, Any], configured_catalog: ConfiguredAirbyteCatalog, input_messages: Iterable[AirbyteMessage] ) -> Iterable[AirbyteMessage]: """ @@ -54,6 +51,3 @@ def check(self, logger: AirbyteLogger, config: Mapping[str, Any]) -> AirbyteConn return AirbyteConnectionStatus(status=Status.SUCCEEDED) except Exception as e: return AirbyteConnectionStatus(status=Status.FAILED, message=f"An exception occurred: {repr(e)}") - - - diff --git a/airbyte-integrations/connectors/destination-scaffold-destination-python/setup.py b/airbyte-integrations/connectors/destination-scaffold-destination-python/setup.py index b51d89f7f091..4e2dbe001f95 100644 --- a/airbyte-integrations/connectors/destination-scaffold-destination-python/setup.py +++ b/airbyte-integrations/connectors/destination-scaffold-destination-python/setup.py @@ -9,9 +9,7 @@ "airbyte-cdk", ] -TEST_REQUIREMENTS = [ - "pytest~=6.1" -] +TEST_REQUIREMENTS = ["pytest~=6.1"] setup( name="destination_scaffold_destination_python", diff --git a/airbyte-integrations/connectors/destination-snowflake/src/main/resources/spec.json b/airbyte-integrations/connectors/destination-snowflake/src/main/resources/spec.json index d65a8b7d7e17..065aa7a01c8a 100644 --- a/airbyte-integrations/connectors/destination-snowflake/src/main/resources/spec.json +++ b/airbyte-integrations/connectors/destination-snowflake/src/main/resources/spec.json @@ -21,7 +21,10 @@ "properties": { "host": { "description": "The host domain of the snowflake instance (must include the account, region, cloud environment, and end with snowflakecomputing.com). The account identifier differs depending on your cloud region, be sure to verify with Snowflake's documentation.", - "examples": ["accountname.us-east-2.aws.snowflakecomputing.com", "accountname.snowflakecomputing.com"], + "examples": [ + "accountname.us-east-2.aws.snowflakecomputing.com", + "accountname.snowflakecomputing.com" + ], "type": "string", "title": "Host", "order": 0 diff --git a/airbyte-integrations/connectors/source-chargebee/source_chargebee/schemas/credit_note.json b/airbyte-integrations/connectors/source-chargebee/source_chargebee/schemas/credit_note.json index 9fe60f807dc5..0a9347e3b2f0 100644 --- a/airbyte-integrations/connectors/source-chargebee/source_chargebee/schemas/credit_note.json +++ b/airbyte-integrations/connectors/source-chargebee/source_chargebee/schemas/credit_note.json @@ -25,7 +25,12 @@ }, "reason_code": { "type": ["string", "null"], - "enum": ["write_off", "subscription_change", "subscription_cancellation", "subscription_pause"] + "enum": [ + "write_off", + "subscription_change", + "subscription_cancellation", + "subscription_pause" + ] }, "status": { "type": ["string", "null"], @@ -440,7 +445,7 @@ "minimum": 1 }, "refund_reason_code": { - "type": ["string","null"] + "type": ["string", "null"] } } } diff --git a/airbyte-integrations/connectors/source-chartmogul/source_chartmogul/schemas/customer_count.json b/airbyte-integrations/connectors/source-chartmogul/source_chartmogul/schemas/customer_count.json index 771eb81f0f9a..64382e2ee087 100644 --- a/airbyte-integrations/connectors/source-chartmogul/source_chartmogul/schemas/customer_count.json +++ b/airbyte-integrations/connectors/source-chartmogul/source_chartmogul/schemas/customer_count.json @@ -1,12 +1,12 @@ { - "$schema": "http://json-schema.org/draft-07/schema#", - "type": "object", - "properties": { - "date": { - "type": ["string"] - }, - "customers": { - "type": ["integer"] - } + "$schema": "http://json-schema.org/draft-07/schema#", + "type": "object", + "properties": { + "date": { + "type": ["string"] + }, + "customers": { + "type": ["integer"] } } +} diff --git a/airbyte-integrations/connectors/source-snowflake/src/test-integration/java/io/airbyte/integrations/io/airbyte/integration_tests/sources/SnowflakeSourceDatatypeTest.java b/airbyte-integrations/connectors/source-snowflake/src/test-integration/java/io/airbyte/integrations/io/airbyte/integration_tests/sources/SnowflakeSourceDatatypeTest.java index a6729a9093a7..bf739e15246b 100644 --- a/airbyte-integrations/connectors/source-snowflake/src/test-integration/java/io/airbyte/integrations/io/airbyte/integration_tests/sources/SnowflakeSourceDatatypeTest.java +++ b/airbyte-integrations/connectors/source-snowflake/src/test-integration/java/io/airbyte/integrations/io/airbyte/integration_tests/sources/SnowflakeSourceDatatypeTest.java @@ -60,8 +60,7 @@ private Database getDatabase() { Map.of( "role", config.get("role").asText(), "warehouse", config.get("warehouse").asText(), - "database", config.get("database").asText() - )); + "database", config.get("database").asText())); } @Override diff --git a/airbyte-integrations/connectors/source-woocommerce/source_woocommerce/schemas/shared/meta_data.json b/airbyte-integrations/connectors/source-woocommerce/source_woocommerce/schemas/shared/meta_data.json index 11390151bcdc..d528f9cc24b5 100644 --- a/airbyte-integrations/connectors/source-woocommerce/source_woocommerce/schemas/shared/meta_data.json +++ b/airbyte-integrations/connectors/source-woocommerce/source_woocommerce/schemas/shared/meta_data.json @@ -1,6 +1,6 @@ { "type": ["null", "array", "object"], - "oneOf" : [ + "oneOf": [ { "type": ["null", "object"], "properties": { @@ -15,22 +15,22 @@ } } }, - { - "type" : "array", - "items": { - "type": ["null", "object"], - "properties": { - "id": { - "type": ["null", "integer"] - }, - "key": { - "type": ["null", "string"] - }, - "value": { - "type": ["null", "object", "string"] + { + "type": "array", + "items": { + "type": ["null", "object"], + "properties": { + "id": { + "type": ["null", "integer"] + }, + "key": { + "type": ["null", "string"] + }, + "value": { + "type": ["null", "object", "string"] + } } } - } } ] }