Update factory

Author: lazebnyi

airbyte_cdk/sources/declarative/declarative_component_schema.yaml

@@ -1743,7 +1743,7 @@ definitions:
         additionalProperties: true
   KeyValueExtractor:
     title: Key Value Extractor
-    description: Record extractor that extract with .
+    description: Record extractor that combines keys and values from two separate extractors.
     type: object
     required:
       - type
@@ -1754,12 +1754,10 @@ definitions:
         type: string
         enum: [ KeyValueExtractor ]
       keys_extractor:
-        description: placeholder
         anyOf:
           - "$ref": "#/definitions/DpathExtractor"
           - "$ref": "#/definitions/CustomRecordExtractor"
       values_extractor:
-        description: placeholder
         anyOf:
           - "$ref": "#/definitions/DpathExtractor"
           - "$ref": "#/definitions/CustomRecordExtractor"

airbyte_cdk/sources/declarative/models/declarative_component_schema.py

@@ -1852,12 +1852,8 @@ class DefaultPaginator(BaseModel):
 
 class KeyValueExtractor(BaseModel):
     type: Literal["KeyValueExtractor"]
-    keys_extractor: Union[DpathExtractor, CustomRecordExtractor] = Field(
-        ..., description="placeholder"
-    )
-    values_extractor: Union[DpathExtractor, CustomRecordExtractor] = Field(
-        ..., description="placeholder"
-    )
+    keys_extractor: Union[DpathExtractor, CustomRecordExtractor]
+    values_extractor: Union[DpathExtractor, CustomRecordExtractor]
     parameters: Optional[Dict[str, Any]] = Field(None, alias="$parameters")
 
 

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

@@ -2453,14 +2453,10 @@ def create_dynamic_schema_loader(
         schema_type_identifier = self._create_component_from_model(
             model.schema_type_identifier, config=config, parameters=model.parameters or {}
         )
-        schema_filter = self._create_component_from_model(
-            model.schema_filter, config=config, parameters=model.parameters or {}
-        )
         return DynamicSchemaLoader(
             retriever=retriever,
             config=config,
             schema_transformations=schema_transformations,
-            schema_filter=schema_filter,
             schema_type_identifier=schema_type_identifier,
             parameters=model.parameters or {},
         )
@@ -3622,7 +3618,6 @@ def create_components_mapping_definition(
             field_path=field_path,  # type: ignore[arg-type] # field_path can be str and InterpolatedString
             value=interpolated_value,
             value_type=ModelToComponentFactory._json_schema_type_name_to_type(model.value_type),
-            create_or_update=model.create_or_update,
             parameters=model.parameters or {},
         )
 
@@ -3669,24 +3664,16 @@ def create_stream_config(
 
         return StreamConfig(
             configs_pointer=model_configs_pointer,
-            default_values=model.default_values,
             parameters=model.parameters or {},
         )
 
     def create_config_components_resolver(
         self, model: ConfigComponentsResolverModel, config: Config
     ) -> Any:
-        model_stream_configs = (
-            model.stream_config if isinstance(model.stream_config, list) else [model.stream_config]
+        stream_config = self._create_component_from_model(
+            model.stream_config, config=config, parameters=model.parameters or {}
         )
 
-        stream_configs = [
-            self._create_component_from_model(
-                stream_config, config=config, parameters=model.parameters or {}
-            )
-            for stream_config in model_stream_configs
-        ]
-
         components_mapping = [
             self._create_component_from_model(
                 model=components_mapping_definition_model,
@@ -3699,7 +3686,7 @@ def create_config_components_resolver(
         ]
 
         return ConfigComponentsResolver(
-            stream_configs=stream_configs,
+            stream_config=stream_config,
             config=config,
             components_mapping=components_mapping,
             parameters=model.parameters or {},