Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Destination Redshift: deprecate old migration normalization code #25771

Conversation

cynthiaxyin
Copy link
Contributor

@cynthiaxyin cynthiaxyin commented May 2, 2023

What

closes #25519

Functionality was added over a year ago (#12064) to migrate Redshift tables from VARCHAR type to SUPER type. Tables have now been SUPER type by default for awhile, so we are removing this old migration code that is no longer needed.

How

Delete migration-related normalization code. Java code was deleted in #25698.

Recommended reading order

  1. configuration.sql and columns.sql (remove macros)
  2. other *.sql (remove usages of macros)

🚨 User Impact 🚨

The set of impacted users is expected to be very small: anyone who has been running old versions of Redshift and Airbyte for over a year and is still using VARCHAR tables with likely stale data. Anyone who is impacted can manually migrate their Redshift tables if needed. The team voted to remove this functionality as it was implemented over a year ago.

@octavia-squidington-iii octavia-squidington-iii added area/documentation Improvements or additions to documentation normalization labels May 2, 2023
@cynthiaxyin

This comment was marked as outdated.

@github-actions
Copy link
Contributor

github-actions bot commented May 2, 2023

Affected Connector Report

NOTE ⚠️ Changes in this PR affect the following connectors. Make sure to do the following as needed:

  • Run integration tests
  • Bump connector or module version
  • Add changelog
  • Publish the new version

✅ Sources (0)

Connector Version Changelog Publish
  • See "Actionable Items" below for how to resolve warnings and errors.

❌ Destinations (15)

Connector Version Changelog Publish
destination-bigquery 1.3.4
destination-bigquery-denormalized 1.3.3
destination-clickhouse 0.2.3
destination-clickhouse-strict-encrypt 0.2.3 🔵
(ignored)
🔵
(ignored)
destination-mssql 0.1.23
destination-mssql-strict-encrypt 0.1.23 🔵
(ignored)
🔵
(ignored)
destination-mysql 0.1.20
destination-mysql-strict-encrypt 0.1.21
(mismatch: 0.1.20)
🔵
(ignored)
🔵
(ignored)
destination-oracle 0.1.19
destination-oracle-strict-encrypt 0.1.19 🔵
(ignored)
🔵
(ignored)
destination-postgres 0.3.27
destination-postgres-strict-encrypt 0.3.27 🔵
(ignored)
🔵
(ignored)
destination-redshift 0.4.7
destination-snowflake 1.0.0
destination-tidb 0.1.1
  • See "Actionable Items" below for how to resolve warnings and errors.

👀 Other Modules (1)

  • base-normalization

Actionable Items

(click to expand)

Category Status Actionable Item
Version
mismatch
The version of the connector is different from its normal variant. Please bump the version of the connector.

doc not found
The connector does not seem to have a documentation file. This can be normal (e.g. basic connector like source-jdbc is not published or documented). Please double-check to make sure that it is not a bug.
Changelog
doc not found
The connector does not seem to have a documentation file. This can be normal (e.g. basic connector like source-jdbc is not published or documented). Please double-check to make sure that it is not a bug.

changelog missing
There is no chnagelog for the current version of the connector. If you are the author of the current version, please add a changelog.
Publish
not in seed
The connector is not in the seed file (e.g. source_definitions.yaml), so its publication status cannot be checked. This can be normal (e.g. some connectors are cloud-specific, and only listed in the cloud seed file). Please double-check to make sure that it is not a bug.

diff seed version
The connector exists in the seed file, but the latest version is not listed there. This usually means that the latest version is not published. Please use the /publish command to publish the latest version.

@cynthiaxyin cynthiaxyin marked this pull request as ready for review May 2, 2023 22:58
@cynthiaxyin cynthiaxyin requested a review from a team as a code owner May 2, 2023 22:58
Copy link
Contributor

@edgao edgao left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@edgao
Copy link
Contributor

edgao commented May 3, 2023

No idea why the /test comment isn't getting uptadet; from the /test raw logs

	 =========================== short test summary info ============================
	 SKIPPED [1] integration_tests/test_drop_scd_overwrite.py:56: DestinationType.ORACLE does not support incremental sync with schema change yet
	 SKIPPED [1] integration_tests/test_drop_scd_overwrite.py:56: DestinationType.TIDB does not support incremental sync with schema change yet
	 SKIPPED [3] integration_tests/test_ephemeral.py:102: ephemeral materialization isn't supported in ClickHouse yet
	 SKIPPED [1] integration_tests/test_ephemeral.py:59: Skipping test for column limit, because in MySQL, the max number of columns is limited by row size (8KB)
	 SKIPPED [1] integration_tests/***.py:82: Destinations DestinationType.CLICKHOUSE does not support nested streams
	 SKIPPED [1] integration_tests/***.py:149: DestinationType.CLICKHOUSE is disabled as it doesnt support schema change in incremental yet (column type changes)
	 SKIPPED [1] integration_tests/***.py:152: DestinationType.MSSQL is disabled as it doesnt fully support schema change in incremental yet
	 SKIPPED [2] integration_tests/***.py:135: DestinationType.MYSQL does not support incremental yet
	 SKIPPED [1] integration_tests/***.py:82: Destinations DestinationType.ORACLE does not support nested streams
	 SKIPPED [1] integration_tests/***.py:135: DestinationType.ORACLE does not support incremental yet
	 SKIPPED [1] integration_tests/***.py:149: DestinationType.SNOWFLAKE is disabled as it doesnt support schema change in incremental yet (column type changes)
	 SKIPPED [1] integration_tests/***.py:149: DestinationType.TIDB is disabled as it doesnt support schema change in incremental yet (column type changes)
	 SKIPPED [1] integration_tests/test_sparse_nested_fields.py:72: Destinations DestinationType.CLICKHOUSE does not support nested streams
	 SKIPPED [1] integration_tests/test_sparse_nested_fields.py:74: DestinationType.MYSQL does not support incremental yet
	 SKIPPED [1] integration_tests/test_sparse_nested_fields.py:72: Destinations DestinationType.ORACLE does not support nested streams
	 FAILED integration_tests/***.py::test_redshift_normalization_migration
	 �[31m============ �[31m�[1m1 failed�[0m, �[32m52 ***ed�[0m, �[33m18 skipped�[0m�[31m in 4017.14s (1:06:57)�[0m�[31m =============�[0m

so yeah, the only failure is the one that's expected to fail now.

@cynthiaxyin cynthiaxyin force-pushed the cynthia/destination_redshift_migration_deprecate_normalization branch from 397d6f5 to da70f49 Compare May 4, 2023 17:29
@cynthiaxyin

This comment was marked as outdated.

@cynthiaxyin

This comment was marked as outdated.

@cynthiaxyin cynthiaxyin force-pushed the cynthia/destination_redshift_migration_deprecate_normalization branch from da70f49 to 1bad657 Compare May 5, 2023 01:06
@cynthiaxyin

This comment was marked as outdated.

@cynthiaxyin
Copy link
Contributor Author

cynthiaxyin commented May 5, 2023

/test connector=bases/base-normalization

🕑 bases/base-normalization https://github.com/airbytehq/airbyte/actions/runs/4896121421
✅ bases/base-normalization https://github.com/airbytehq/airbyte/actions/runs/4896121421
Python tests coverage:

Name                                Stmts   Miss  Cover
-------------------------------------------------------
destination_duckdb/__init__.py          2      0   100%
destination_duckdb/destination.py      70     48    31%
-------------------------------------------------------
TOTAL                                  72     48    33%
Name                                                              Stmts   Miss  Cover
-------------------------------------------------------------------------------------
normalization/transform_config/__init__.py                            2      0   100%
normalization/transform_catalog/reserved_keywords.py                 15      0   100%
normalization/transform_catalog/__init__.py                           2      0   100%
normalization/destination_type.py                                    18      0   100%
normalization/__init__.py                                             4      0   100%
normalization/transform_catalog/destination_name_transformer.py     171     10    94%
normalization/transform_catalog/table_name_registry.py              174     34    80%
normalization/transform_config/transform.py                         195     48    75%
normalization/transform_catalog/utils.py                             51     14    73%
normalization/transform_catalog/dbt_macro.py                         22      7    68%
normalization/transform_catalog/catalog_processor.py                147     80    46%
normalization/transform_catalog/transform.py                         65     39    40%
normalization/transform_catalog/stream_processor.py                 595    400    33%
-------------------------------------------------------------------------------------
TOTAL                                                              1461    632    57%
Name                                                                                                                           Stmts   Miss  Cover
--------------------------------------------------------------------------------------------------------------------------------------------------
airbyte_cdk/utils/traced_exception.py                                                                                             29      0   100%
airbyte_cdk/utils/stream_status_utils.py                                                                                           7      0   100%
airbyte_cdk/utils/schema_inferrer.py                                                                                              26      0   100%
airbyte_cdk/utils/airbyte_secrets_utils.py                                                                                        33      0   100%
airbyte_cdk/utils/__init__.py                                                                                                      3      0   100%
airbyte_cdk/sources/utils/transform.py                                                                                            88      0   100%
airbyte_cdk/sources/utils/schema_models.py                                                                                        38      0   100%
airbyte_cdk/sources/utils/record_helper.py                                                                                        20      0   100%
airbyte_cdk/sources/utils/catalog_helpers.py                                                                                      10      0   100%
airbyte_cdk/sources/utils/casing.py                                                                                                4      0   100%
airbyte_cdk/sources/utils/__init__.py                                                                                              1      0   100%
airbyte_cdk/sources/streams/utils/stream_helper.py                                                                                 9      0   100%
airbyte_cdk/sources/streams/http/requests_native_auth/token.py                                                                    40      0   100%
airbyte_cdk/sources/streams/http/requests_native_auth/__init__.py                                                                  3      0   100%
airbyte_cdk/sources/streams/http/http.py                                                                                         175      0   100%
airbyte_cdk/sources/streams/http/exceptions.py                                                                                    13      0   100%
airbyte_cdk/sources/streams/http/auth/token.py                                                                                    27      0   100%
airbyte_cdk/sources/streams/http/auth/core.py                                                                                     11      0   100%
airbyte_cdk/sources/streams/http/auth/__init__.py                                                                                  4      0   100%
airbyte_cdk/sources/streams/http/__init__.py                                                                                       3      0   100%
airbyte_cdk/sources/streams/__init__.py                                                                                            2      0   100%
airbyte_cdk/sources/singer/__init__.py                                                                                             3      0   100%
airbyte_cdk/sources/declarative/types.py                                                                                           8      0   100%
airbyte_cdk/sources/declarative/transformations/remove_fields.py                                                                  17      0   100%
airbyte_cdk/sources/declarative/transformations/__init__.py                                                                        4      0   100%
airbyte_cdk/sources/declarative/stream_slicers/stream_slicer.py                                                                   14      0   100%
airbyte_cdk/sources/declarative/stream_slicers/cartesian_product_stream_slicer.py                                                 27      0   100%
airbyte_cdk/sources/declarative/stream_slicers/__init__.py                                                                         3      0   100%
airbyte_cdk/sources/declarative/spec/spec.py                                                                                      18      0   100%
airbyte_cdk/sources/declarative/spec/__init__.py                                                                                   2      0   100%
airbyte_cdk/sources/declarative/schema/inline_schema_loader.py                                                                     9      0   100%
airbyte_cdk/sources/declarative/schema/default_schema_loader.py                                                                   20      0   100%
airbyte_cdk/sources/declarative/schema/__init__.py                                                                                 5      0   100%
airbyte_cdk/sources/declarative/retrievers/retriever.py                                                                           18      0   100%
airbyte_cdk/sources/declarative/retrievers/__init__.py                                                                             3      0   100%
airbyte_cdk/sources/declarative/requesters/request_path.py                                                                         5      0   100%
airbyte_cdk/sources/declarative/requesters/request_options/__init__.py                                                             3      0   100%
airbyte_cdk/sources/declarative/requesters/request_option.py                                                                      13      0   100%
airbyte_cdk/sources/declarative/requesters/paginators/strategies/offset_increment.py                                              27      0   100%
airbyte_cdk/sources/declarative/requesters/paginators/strategies/__init__.py                                                       4      0   100%
airbyte_cdk/sources/declarative/requesters/paginators/__init__.py                                                                  5      0   100%
airbyte_cdk/sources/declarative/requesters/error_handlers/response_action.py                                                       6      0   100%
airbyte_cdk/sources/declarative/requesters/error_handlers/backoff_strategy.py                                                      8      0   100%
airbyte_cdk/sources/declarative/requesters/error_handlers/backoff_strategies/wait_time_from_header_backoff_strategy.py            21      0   100%
airbyte_cdk/sources/declarative/requesters/error_handlers/backoff_strategies/exponential_backoff_strategy.py                      17      0   100%
airbyte_cdk/sources/declarative/requesters/error_handlers/backoff_strategies/constant_backoff_strategy.py                         17      0   100%
airbyte_cdk/sources/declarative/requesters/error_handlers/backoff_strategies/__init__.py                                           5      0   100%
airbyte_cdk/sources/declarative/requesters/error_handlers/__init__.py                                                              6      0   100%
airbyte_cdk/sources/declarative/requesters/__init__.py                                                                             4      0   100%
airbyte_cdk/sources/declarative/partition_routers/__init__.py                                                                      4      0   100%
airbyte_cdk/sources/declarative/parsers/manifest_component_transformer.py                                                         40      0   100%
airbyte_cdk/sources/declarative/parsers/custom_exceptions.py                                                                       6      0   100%
airbyte_cdk/sources/declarative/models/declarative_component_schema.py                                                           348      0   100%
airbyte_cdk/sources/declarative/models/__init__.py                                                                                 1      0   100%
airbyte_cdk/sources/declarative/interpolation/interpolated_mapping.py                                                             18      0   100%
airbyte_cdk/sources/declarative/interpolation/__init__.py                                                                          4      0   100%
airbyte_cdk/sources/declarative/incremental/__init__.py                                                                            2      0   100%
airbyte_cdk/sources/declarative/extractors/record_selector.py                                                                     19      0   100%
airbyte_cdk/sources/declarative/extractors/record_filter.py                                                                       16      0   100%
airbyte_cdk/sources/declarative/extractors/__init__.py                                                                             5      0   100%
airbyte_cdk/sources/declarative/exceptions.py                                                                                      1      0   100%
airbyte_cdk/sources/declarative/decoders/json_decoder.py                                                                          12      0   100%
airbyte_cdk/sources/declarative/decoders/__init__.py                                                                               3      0   100%
airbyte_cdk/sources/declarative/datetime/min_max_datetime.py                                                                      41      0   100%
airbyte_cdk/sources/declarative/datetime/datetime_parser.py                                                                       16      0   100%
airbyte_cdk/sources/declarative/datetime/__init__.py                                                                               2      0   100%
airbyte_cdk/sources/declarative/checks/__init__.py                                                                                 3      0   100%
airbyte_cdk/sources/declarative/auth/oauth.py                                                                                     67      0   100%
airbyte_cdk/sources/declarative/auth/__init__.py                                                                                   2      0   100%
airbyte_cdk/sources/connector_state_manager.py                                                                                    76      0   100%
airbyte_cdk/sources/config.py                                                                                                     11      0   100%
airbyte_cdk/sources/__init__.py                                                                                                    4      0   100%
airbyte_cdk/models/well_known_types.py                                                                                             1      0   100%
airbyte_cdk/models/airbyte_protocol.py                                                                                             1      0   100%
airbyte_cdk/models/__init__.py                                                                                                     2      0   100%
airbyte_cdk/destinations/__init__.py                                                                                               2      0   100%
airbyte_cdk/connector_builder/models.py                                                                                           41      0   100%
airbyte_cdk/__init__.py                                                                                                            4      0   100%
airbyte_cdk/sources/declarative/incremental/datetime_based_cursor.py                                                             116      1    99%
airbyte_cdk/sources/abstract_source.py                                                                                           168      2    99%
airbyte_cdk/sources/declarative/retrievers/simple_retriever.py                                                                   192      3    98%
airbyte_cdk/sources/declarative/parsers/manifest_reference_resolver.py                                                            56      1    98%
airbyte_cdk/sources/declarative/requesters/error_handlers/http_response_filter.py                                                 54      1    98%
airbyte_cdk/sources/declarative/partition_routers/list_partition_router.py                                                        44      1    98%
airbyte_cdk/config_observation.py                                                                                                 44      1    98%
airbyte_cdk/sources/declarative/requesters/error_handlers/backoff_strategies/wait_until_time_from_header_backoff_strategy.py      41      1    98%
airbyte_cdk/sources/declarative/requesters/request_options/interpolated_request_options_provider.py                               40      1    98%
airbyte_cdk/sources/declarative/interpolation/jinja.py                                                                            40      1    98%
airbyte_cdk/sources/declarative/requesters/requester.py                                                                           39      1    97%
airbyte_cdk/sources/declarative/auth/token.py                                                                                    114      3    97%
airbyte_cdk/sources/streams/http/requests_native_auth/abstract_oauth.py                                                           75      2    97%
airbyte_cdk/sources/declarative/requesters/paginators/strategies/cursor_pagination_strategy.py                                    36      1    97%
airbyte_cdk/sources/declarative/requesters/http_requester.py                                                                      69      2    97%
airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py                                                            370     11    97%
airbyte_cdk/sources/declarative/extractors/dpath_extractor.py                                                                     32      1    97%
airbyte_cdk/sources/declarative/checks/check_stream.py                                                                            31      1    97%
airbyte_cdk/sources/streams/http/auth/oauth.py                                                                                    58      2    97%
airbyte_cdk/sources/declarative/requesters/error_handlers/default_error_handler.py                                                54      2    96%
airbyte_cdk/sources/streams/http/requests_native_auth/oauth.py                                                                   107      4    96%
airbyte_cdk/sources/declarative/requesters/error_handlers/composite_error_handler.py                                              26      1    96%
airbyte_cdk/connector_builder/message_grouper.py                                                                                 126      5    96%
airbyte_cdk/sources/streams/core.py                                                                                              100      4    96%
airbyte_cdk/sources/declarative/interpolation/interpolated_string.py                                                              24      1    96%
airbyte_cdk/sources/declarative/declarative_stream.py                                                                             71      3    96%
airbyte_cdk/sources/source.py                                                                                                     45      2    96%
airbyte_cdk/sources/declarative/requesters/error_handlers/backoff_strategies/header_helper.py                                     22      1    95%
airbyte_cdk/sources/declarative/partition_routers/single_partition_router.py                                                      22      1    95%
airbyte_cdk/connector_builder/connector_builder_handler.py                                                                        66      3    95%
airbyte_cdk/sources/declarative/partition_routers/substream_partition_router.py                                                   81      4    95%
airbyte_cdk/sources/declarative/requesters/paginators/strategies/page_increment.py                                                20      1    95%
airbyte_cdk/sources/declarative/interpolation/interpolated_boolean.py                                                             20      1    95%
airbyte_cdk/sources/declarative/transformations/add_fields.py                                                                     38      2    95%
airbyte_cdk/sources/streams/http/availability_strategy.py                                                                         56      3    95%
airbyte_cdk/sources/streams/http/requests_native_auth/abstract_token.py                                                           17      1    94%
airbyte_cdk/utils/event_timing.py                                                                                                 48      3    94%
airbyte_cdk/sources/declarative/interpolation/macros.py                                                                           31      2    94%
airbyte_cdk/sources/utils/schema_helpers.py                                                                                       92      6    93%
airbyte_cdk/sources/declarative/requesters/request_options/request_options_provider.py                                            15      1    93%
airbyte_cdk/connector.py                                                                                                          72      5    93%
airbyte_cdk/sources/declarative/manifest_declarative_source.py                                                                   108      8    93%
airbyte_cdk/sources/declarative/requesters/paginators/default_paginator.py                                                        79      6    92%
airbyte_cdk/sources/declarative/requesters/paginators/strategies/pagination_strategy.py                                           13      1    92%
airbyte_cdk/sources/declarative/interpolation/filters.py                                                                          13      1    92%
airbyte_cdk/sources/declarative/requesters/request_options/interpolated_request_input_provider.py                                 24      2    92%
airbyte_cdk/sources/streams/http/rate_limiting.py                                                                                 34      3    91%
airbyte_cdk/sources/declarative/requesters/error_handlers/response_status.py                                                      32      3    91%
airbyte_cdk/sources/streams/availability_strategy.py                                                                              10      1    90%
airbyte_cdk/sources/declarative/transformations/transformation.py                                                                 10      1    90%
airbyte_cdk/sources/declarative/extractors/record_extractor.py                                                                    10      1    90%
airbyte_cdk/sources/declarative/extractors/http_selector.py                                                                       10      1    90%
airbyte_cdk/sources/declarative/declarative_source.py                                                                             10      1    90%
airbyte_cdk/sources/declarative/decoders/decoder.py                                                                                9      1    89%
airbyte_cdk/destinations/destination.py                                                                                           80      9    89%
source_declarative_manifest/main.py                                                                                               16      2    88%
airbyte_cdk/sources/declarative/schema/schema_loader.py                                                                            8      1    88%
airbyte_cdk/sources/declarative/checks/connection_checker.py                                                                       8      1    88%
airbyte_cdk/sources/declarative/requesters/paginators/paginator.py                                                                15      2    87%
airbyte_cdk/entrypoint.py                                                                                                        116     16    86%
airbyte_cdk/sources/declarative/requesters/error_handlers/error_handler.py                                                        14      2    86%
airbyte_cdk/sources/declarative/interpolation/interpolation.py                                                                     7      1    86%
airbyte_cdk/sources/declarative/auth/declarative_authenticator.py                                                                 14      2    86%
airbyte_cdk/exception_handler.py                                                                                                  12      2    83%
airbyte_cdk/sources/declarative/schema/json_file_schema_loader.py                                                                 48      9    81%
airbyte_cdk/connector_builder/main.py                                                                                             44      9    80%
airbyte_cdk/sources/declarative/create_partial.py                                                                                 46     10    78%
airbyte_cdk/sources/declarative/requesters/paginators/no_pagination.py                                                            22      5    77%
airbyte_cdk/sources/declarative/yaml_declarative_source.py                                                                        20      6    70%
airbyte_cdk/logger.py                                                                                                             62     20    68%
airbyte_cdk/sources/singer/source.py                                                                                              83     32    61%
airbyte_cdk/sources/singer/singer_helpers.py                                                                                     175     94    46%
--------------------------------------------------------------------------------------------------------------------------------------------------
TOTAL                                                                                                                           5514    346    94%
	 Name                                                    Stmts   Miss  Cover   Missing
	 -------------------------------------------------------------------------------------
	 connector_acceptance_test/base.py                          12      4    67%   16-19
	 connector_acceptance_test/config.py                       153      8    95%   87, 93, 252, 256, 261-262, 267-268
	 connector_acceptance_test/conftest.py                     233    106    55%   38, 44-46, 51, 56, 61, 84, 90, 96-98, 117, 122-124, 130-132, 138-139, 144-145, 150, 161, 170-179, 185-190, 217, 241, 272, 278, 286-294, 306-325, 333-346, 351-357, 364-375, 382-398
	 connector_acceptance_test/plugin.py                        69     25    64%   22-23, 31, 36, 120-140, 144-148
	 connector_acceptance_test/tests/test_core.py              535     95    82%   55, 60, 99-110, 115-122, 126-127, 131-132, 382, 402, 427, 507, 545-564, 577-588, 592-597, 603, 636-641, 679-686, 825-828, 833, 838, 898-899, 905, 945-955, 972-973, 975, 993-998
	 connector_acceptance_test/tests/test_incremental.py       162     14    91%   58-65, 70-83, 252
	 connector_acceptance_test/utils/asserts.py                 48      2    96%   78-79
	 connector_acceptance_test/utils/common.py                  94     10    89%   16-17, 32-38, 72, 75
	 connector_acceptance_test/utils/compare.py                 64     23    64%   21-51, 68, 101-103
	 connector_acceptance_test/utils/connector_runner.py       134     33    75%   30-33, 53-54, 57-61, 64-65, 80-82, 85-87, 90-92, 95-97, 100-102, 132-133, 167-169, 216
	 connector_acceptance_test/utils/json_schema_helper.py     117     13    89%   31-32, 39, 42, 66-69, 97, 121, 210-212
	 -------------------------------------------------------------------------------------
	 TOTAL                                                    1812    333    82%
Name                                Stmts   Miss  Cover
-------------------------------------------------------
destination_duckdb/__init__.py          2      0   100%
destination_duckdb/destination.py      70     48    31%
-------------------------------------------------------
TOTAL                                  72     48    33%
Name                                                              Stmts   Miss  Cover
-------------------------------------------------------------------------------------
normalization/transform_config/__init__.py                            2      0   100%
normalization/transform_catalog/reserved_keywords.py                 15      0   100%
normalization/transform_catalog/__init__.py                           2      0   100%
normalization/destination_type.py                                    18      0   100%
normalization/__init__.py                                             4      0   100%
normalization/transform_catalog/destination_name_transformer.py     171     10    94%
normalization/transform_catalog/table_name_registry.py              174     34    80%
normalization/transform_config/transform.py                         195     48    75%
normalization/transform_catalog/utils.py                             51     14    73%
normalization/transform_catalog/dbt_macro.py                         22      7    68%
normalization/transform_catalog/catalog_processor.py                147     80    46%
normalization/transform_catalog/transform.py                         65     39    40%
normalization/transform_catalog/stream_processor.py                 595    400    33%
-------------------------------------------------------------------------------------
TOTAL                                                              1461    632    57%
Name                                                              Stmts   Miss  Cover
-------------------------------------------------------------------------------------
normalization/transform_config/__init__.py                            2      0   100%
normalization/transform_catalog/reserved_keywords.py                 15      0   100%
normalization/transform_catalog/__init__.py                           2      0   100%
normalization/destination_type.py                                    18      0   100%
normalization/__init__.py                                             4      0   100%
normalization/transform_catalog/utils.py                             51      1    98%
normalization/transform_catalog/destination_name_transformer.py     171     10    94%
normalization/transform_catalog/stream_processor.py                 595     38    94%
normalization/transform_catalog/catalog_processor.py                147     12    92%
normalization/transform_catalog/dbt_macro.py                         22      3    86%
normalization/transform_catalog/table_name_registry.py              174     51    71%
normalization/transform_catalog/transform.py                         65     25    62%
normalization/transform_config/transform.py                         195     80    59%
-------------------------------------------------------------------------------------
TOTAL                                                              1461    220    85%

Build Passed

Test summary info:

	 =========================== short test summary info ============================
	 SKIPPED [1] integration_tests/test_drop_scd_overwrite.py:56: DestinationType.ORACLE does not support incremental sync with schema change yet
	 SKIPPED [1] integration_tests/test_drop_scd_overwrite.py:56: DestinationType.TIDB does not support incremental sync with schema change yet
	 SKIPPED [3] integration_tests/test_ephemeral.py:102: ephemeral materialization isn't supported in ClickHouse yet
	 SKIPPED [1] integration_tests/test_ephemeral.py:59: Skipping test for column limit, because in MySQL, the max number of columns is limited by row size (8KB)
	 SKIPPED [1] integration_tests/test_normalization.py:148: DestinationType.CLICKHOUSE is disabled as it doesnt support schema change in incremental yet (column type changes)
	 SKIPPED [1] integration_tests/test_normalization.py:81: Destinations DestinationType.CLICKHOUSE does not support nested streams
	 SKIPPED [1] integration_tests/test_normalization.py:151: DestinationType.MSSQL is disabled as it doesnt fully support schema change in incremental yet
	 SKIPPED [2] integration_tests/test_normalization.py:134: DestinationType.MYSQL does not support incremental yet
	 SKIPPED [1] integration_tests/test_normalization.py:134: DestinationType.ORACLE does not support incremental yet
	 SKIPPED [1] integration_tests/test_normalization.py:81: Destinations DestinationType.ORACLE does not support nested streams
	 SKIPPED [1] integration_tests/test_normalization.py:148: DestinationType.SNOWFLAKE is disabled as it doesnt support schema change in incremental yet (column type changes)
	 SKIPPED [1] integration_tests/test_normalization.py:148: DestinationType.TIDB is disabled as it doesnt support schema change in incremental yet (column type changes)
	 SKIPPED [1] integration_tests/test_sparse_nested_fields.py:72: Destinations DestinationType.CLICKHOUSE does not support nested streams
	 SKIPPED [1] integration_tests/test_sparse_nested_fields.py:74: DestinationType.MYSQL does not support incremental yet
	 SKIPPED [1] integration_tests/test_sparse_nested_fields.py:72: Destinations DestinationType.ORACLE does not support nested streams
	 �[32m================= �[32m�[1m52 passed�[0m, �[33m18 skipped�[0m�[32m in 4383.78s (1:13:03)�[0m�[32m ==================�[0m
	 =========================== short test summary info ============================
	 SKIPPED [1] integration_tests/test_drop_scd_overwrite.py:56: DestinationType.ORACLE does not support incremental sync with schema change yet
	 SKIPPED [1] integration_tests/test_drop_scd_overwrite.py:56: DestinationType.TIDB does not support incremental sync with schema change yet
	 SKIPPED [3] integration_tests/test_ephemeral.py:102: ephemeral materialization isn't supported in ClickHouse yet
	 SKIPPED [1] integration_tests/test_ephemeral.py:59: Skipping test for column limit, because in MySQL, the max number of columns is limited by row size (8KB)
	 SKIPPED [1] integration_tests/test_normalization.py:148: DestinationType.CLICKHOUSE is disabled as it doesnt support schema change in incremental yet (column type changes)
	 SKIPPED [1] integration_tests/test_normalization.py:81: Destinations DestinationType.CLICKHOUSE does not support nested streams
	 SKIPPED [1] integration_tests/test_normalization.py:151: DestinationType.MSSQL is disabled as it doesnt fully support schema change in incremental yet
	 SKIPPED [2] integration_tests/test_normalization.py:134: DestinationType.MYSQL does not support incremental yet
	 SKIPPED [1] integration_tests/test_normalization.py:134: DestinationType.ORACLE does not support incremental yet
	 SKIPPED [1] integration_tests/test_normalization.py:81: Destinations DestinationType.ORACLE does not support nested streams
	 SKIPPED [1] integration_tests/test_normalization.py:148: DestinationType.SNOWFLAKE is disabled as it doesnt support schema change in incremental yet (column type changes)
	 SKIPPED [1] integration_tests/test_normalization.py:148: DestinationType.TIDB is disabled as it doesnt support schema change in incremental yet (column type changes)
	 SKIPPED [1] integration_tests/test_sparse_nested_fields.py:72: Destinations DestinationType.CLICKHOUSE does not support nested streams
	 SKIPPED [1] integration_tests/test_sparse_nested_fields.py:74: DestinationType.MYSQL does not support incremental yet
	 SKIPPED [1] integration_tests/test_sparse_nested_fields.py:72: Destinations DestinationType.ORACLE does not support nested streams
	 �[32m================= �[32m�[1m52 passed�[0m, �[33m18 skipped�[0m�[32m in 4136.92s (1:08:56)�[0m�[32m ==================�[0m

@cynthiaxyin
Copy link
Contributor Author

cynthiaxyin commented May 5, 2023

/publish connector=bases/base-normalization run-tests=false

🕑 Publishing the following connectors:
bases/base-normalization
https://github.com/airbytehq/airbyte/actions/runs/4897511474


Connector Version Did it publish? Were definitions generated?
bases/base-normalization

if you have connectors that successfully published but failed definition generation, follow step 4 here ▶️

@cynthiaxyin cynthiaxyin merged commit 8400d20 into master May 5, 2023
@cynthiaxyin cynthiaxyin deleted the cynthia/destination_redshift_migration_deprecate_normalization branch May 5, 2023 21:18
marcosmarxm pushed a commit to natalia-miinto/airbyte that referenced this pull request Jun 8, 2023
…bytehq#25771)

* first pass normalization

* add pr link

* remove python test & resources

* linting
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
area/documentation Improvements or additions to documentation normalization
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Remove Redshift VARCHAR to SUPER migration code
3 participants