Format code

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,
 

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,
 

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,

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,
 

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,
 

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,
 

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,

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,

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,

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,
 

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,

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": {

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",

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)}")
-
-
-

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",

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

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"]
           }
         }
       }

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"]
     }
   }
+}

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