Merge branch 'master' into btkcodedev/faunaMigrtepoetry

Author: natikgadzhi

airbyte-ci/connectors/pipelines/pipelines/airbyte_ci/connectors/commands.py

@@ -149,6 +149,7 @@ def validate_environment(is_local: bool) -> None:
         "publish": "pipelines.airbyte_ci.connectors.publish.commands.publish",
         "bump-version": "pipelines.airbyte_ci.connectors.bump_version.commands.bump_version",
         "migrate-to-manifest-only": "pipelines.airbyte_ci.connectors.migrate_to_manifest_only.commands.migrate_to_manifest_only",
+        "migrate-to-inline-schemas": "pipelines.airbyte_ci.connectors.migrate_to_inline_schemas.commands.migrate_to_inline_schemas",
         "generate-erd": "pipelines.airbyte_ci.connectors.generate_erd.commands.generate_erd",
         "upgrade-cdk": "pipelines.airbyte_ci.connectors.upgrade_cdk.commands.upgrade_cdk",
         "up-to-date": "pipelines.airbyte_ci.connectors.up_to_date.commands.up_to_date",

airbyte-ci/connectors/pipelines/pipelines/airbyte_ci/connectors/consts.py

@@ -35,6 +35,9 @@ class CONNECTOR_TEST_STEP_ID(str, Enum):
     MANIFEST_ONLY_CHECK = "migrate_to_manifest_only.check"
     MANIFEST_ONLY_STRIP = "migrate_to_manifest_only.strip"
     MANIFEST_ONLY_UPDATE = "migrate_to_manifest_only.update"
+    INLINE_CANDIDATE = "migration_to_inline_schemas.candidate"
+    INLINE_MIGRATION = "migration_to_inline_schemas.migration"
+    INLINE_CLEANUP = "migration_to_inline_schemas.cleanup"
     LOAD_IMAGE_TO_LOCAL_DOCKER_HOST = "load_image_to_local_docker_host"
 
     def __str__(self) -> str:

airbyte-ci/connectors/pipelines/pipelines/airbyte_ci/connectors/migrate_to_inline_schemas/__init__.py

@@ -0,0 +1,3 @@
+#
+# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
+#

airbyte-ci/connectors/pipelines/pipelines/airbyte_ci/connectors/migrate_to_inline_schemas/commands.py

@@ -0,0 +1,33 @@
+#
+# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
+#
+
+
+import asyncclick as click
+
+from pipelines.airbyte_ci.connectors.migrate_to_inline_schemas.pipeline import run_connector_migrate_to_inline_schemas_pipeline
+from pipelines.cli.dagger_pipeline_command import DaggerPipelineCommand
+from pipelines.helpers.connectors.command import run_connector_pipeline
+from pipelines.helpers.connectors.format import verify_formatters
+
+
+@click.command(
+    cls=DaggerPipelineCommand,
+    short_help="Where possible (have a metadata.yaml), move stream schemas to inline schemas.",
+)
+@click.option(
+    "--report",
+    is_flag=True,
+    type=bool,
+    default=False,
+    help="Auto open report browser.",
+)
+@click.pass_context
+async def migrate_to_inline_schemas(ctx: click.Context, report: bool) -> bool:
+    verify_formatters()
+    return await run_connector_pipeline(
+        ctx,
+        "Migrate to inline schemas",
+        report,
+        run_connector_migrate_to_inline_schemas_pipeline,
+    )