update per comments

Author: pnilan

airbyte_cdk/sources/declarative/declarative_component_schema.yaml

@@ -3814,6 +3814,7 @@ definitions:
             type: array
             items:
               "$ref": "#/definitions/ConfigMigration"
+            default: []
           transformations:
             title: Transformations
             description: The list of transformations that will be applied on the incoming config at the start of each sync. The transformations will be applied in the order they are defined.
@@ -3823,6 +3824,7 @@ definitions:
                 - "$ref": "#/definitions/ConfigRemapField"
                 - "$ref": "#/definitions/ConfigAddFields"
                 - "$ref": "#/definitions/ConfigRemoveFields"
+            default: []
           validations:
             title: Validations
             description: The list of validations that will be performed on the incoming config at the start of each sync.
@@ -3831,13 +3833,18 @@ definitions:
               anyOf:
                 - "$ref": "#/definitions/DpathValidator"
                 - "$ref": "#/definitions/PredicateValidator"
+            default: []
   ConfigMigration:
     title: Config Migration
     description: A config migration that will be applied on the incoming config at the start of a sync.
     type: object
     required:
+      - type
       - transformations
     properties:
+      type:
+        type: string
+        enum: [ConfigMigration]
       description:
         type: string
         description: The description/purpose of the config migration.
@@ -4238,7 +4245,7 @@ definitions:
           - ["data", "{{ parameters.name }}"]
           - ["data", "*", "record"]
       validation_strategy:
-        title: Validation Stragey
+        title: Validation Strategy
         description: The condition that the specified config value will be evaluated against
         anyOf:
           - "$ref": "#/definitions/ValidateAdheresToSchema"

airbyte_cdk/sources/declarative/models/declarative_component_schema.py

@@ -1,3 +1,5 @@
+# Copyright (c) 2025 Airbyte, Inc., all rights reserved.
+
 # generated by datamodel-codegen:
 #   filename:  declarative_component_schema.yaml
 
@@ -1995,7 +1997,7 @@ class DpathValidator(BaseModel):
     validation_strategy: ValidateAdheresToSchema = Field(
         ...,
         description="The condition that the specified config value will be evaluated against",
-        title="Validation Stragey",
+        title="Validation Strategy",
     )
 
 
@@ -2094,6 +2096,7 @@ class Config:
 
 
 class ConfigMigration(BaseModel):
+    type: Literal["ConfigMigration"]
     description: Optional[str] = Field(
         None, description="The description/purpose of the config migration."
     )
@@ -2109,19 +2112,19 @@ class Config:
         extra = Extra.forbid
 
     config_migrations: Optional[List[ConfigMigration]] = Field(
-        None,
+        [],
         description="The discrete migrations that will be applied on the incoming config. Each migration will be applied in the order they are defined.",
         title="Config Migrations",
     )
     transformations: Optional[
         List[Union[ConfigRemapField, ConfigAddFields, ConfigRemoveFields]]
     ] = Field(
-        None,
+        [],
         description="The list of transformations that will be applied on the incoming config at the start of each sync. The transformations will be applied in the order they are defined.",
         title="Transformations",
     )
     validations: Optional[List[Union[DpathValidator, PredicateValidator]]] = Field(
-        None,
+        [],
         description="The list of validations that will be performed on the incoming config at the start of each sync.",
         title="Validations",
     )

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

@@ -499,7 +499,7 @@
     RequestOptionsProvider,
 )
 from airbyte_cdk.sources.declarative.requesters.request_path import RequestPath
-from airbyte_cdk.sources.declarative.requesters.requester import HttpMethod
+from airbyte_cdk.sources.declarative.requesters.requester import HttpMethod, Requester
 from airbyte_cdk.sources.declarative.resolvers import (
     ComponentMappingDefinition,
     ConfigComponentsResolver,
@@ -542,6 +542,9 @@
     ConfigRemapField,
     ConfigRemoveFields,
 )
+from airbyte_cdk.sources.declarative.transformations.config_transformations.config_transformation import (
+    ConfigTransformation,
+)
 from airbyte_cdk.sources.declarative.transformations.dpath_flatten_fields import (
     DpathFlattenFields,
     KeyTransformation,
@@ -823,9 +826,10 @@ def _collect_model_deprecations(self, model: BaseModelWithDeprecations) -> None:
     def create_config_migration(
         self, model: ConfigMigrationModel, config: Config
     ) -> ConfigMigration:
-        transformations = []
-        for transformation in model.transformations:
-            transformations.append(self._create_component_from_model(transformation, config))
+        transformations: List[ConfigTransformation] = [
+            self._create_component_from_model(transformation, config)
+            for transformation in model.transformations
+        ]
 
         return ConfigMigration(
             description=model.description,
@@ -3604,24 +3608,39 @@ def _get_job_timeout() -> datetime.timedelta:
         )
 
     def create_spec(self, model: SpecModel, config: Config, **kwargs: Any) -> Spec:
-        config_migrations = []
-        config_transformations = []
-        config_validations = []
-
-        if model.config_normalization_rules:
-            if model.config_normalization_rules.config_migrations:
-                for migration in model.config_normalization_rules.config_migrations:
-                    config_migrations.append(self._create_component_from_model(migration, config))
-
-            if model.config_normalization_rules.transformations:
-                for transformation in model.config_normalization_rules.transformations:
-                    config_transformations.append(
-                        self._create_component_from_model(transformation, config)
-                    )
-
-            if model.config_normalization_rules.validations:
-                for validation in model.config_normalization_rules.validations:
-                    config_validations.append(self._create_component_from_model(validation, config))
+        config_migrations = [
+            self._create_component_from_model(migration, config)
+            for migration in (
+                model.config_normalization_rules.config_migrations
+                if (
+                    model.config_normalization_rules
+                    and model.config_normalization_rules.config_migrations
+                )
+                else []
+            )
+        ]
+        config_transformations = [
+            self._create_component_from_model(transformation, config)
+            for transformation in (
+                model.config_normalization_rules.transformations
+                if (
+                    model.config_normalization_rules
+                    and model.config_normalization_rules.transformations
+                )
+                else []
+            )
+        ]
+        config_validations = [
+            self._create_component_from_model(validation, config)
+            for validation in (
+                model.config_normalization_rules.validations
+                if (
+                    model.config_normalization_rules
+                    and model.config_normalization_rules.validations
+                )
+                else []
+            )
+        ]
 
         return Spec(
             connection_specification=model.connection_specification,

airbyte_cdk/sources/declarative/spec/spec.py

@@ -98,19 +98,14 @@ def migrate_config(
             for message in self.message_repository.consume_queue():
                 print(orjson.dumps(AirbyteMessageSerializer.dump(message)).decode())
 
-    def transform_config(self, config: MutableMapping[str, Any]) -> MutableMapping[str, Any]:
+    def transform_config(self, config: MutableMapping[str, Any]) -> None:
         """
         Apply all config transformations to the provided config.
 
         :param config: The user-provided configuration
-        :return: The transformed configuration
         """
-        mutable_config = dict(config)
-
         for transformation in self.config_transformations:
-            transformation.transform(mutable_config)
-
-        return mutable_config
+            transformation.transform(config)
 
     def validate_config(self, config: MutableMapping[str, Any]) -> None:
         """