Remove not related changes

Author: lazebnyi

airbyte_cdk/sources/declarative/declarative_component_schema.yaml

@@ -1766,29 +1766,6 @@ definitions:
       $parameters:
         type: object
         additionalProperties: true
-  CombinedExtractor:
-    title: Combined Extractor
-    description: Record extractor that extract with .
-    type: object
-    required:
-      - type
-      - extractors
-    properties:
-      type:
-        type: string
-        enum: [ CombinedExtractor ]
-      extractors:
-        description: placeholder
-        type: array
-        items:
-          anyOf:
-            - "$ref": "#/definitions/DpathExtractor"
-            - "$ref": "#/definitions/CombinedExtractor"
-            - "$ref": "#/definitions/KeyValueExtractor"
-            - "$ref": "#/definitions/CustomRecordExtractor"
-      $parameters:
-        type: object
-        additionalProperties: true
   DpathExtractor:
     title: Dpath Extractor
     description: Record extractor that searches a decoded response over a path defined as an array of fields.
@@ -2366,12 +2343,6 @@ definitions:
           - "$ref": "#/definitions/AsyncRetriever"
           - "$ref": "#/definitions/CustomRetriever"
           - "$ref": "#/definitions/SimpleRetriever"
-      schema_filter:
-        title: Schema Filter
-        description: placeholder
-        anyOf:
-          - "$ref": "#/definitions/RecordFilter"
-          - "$ref": "#/definitions/CustomRecordFilter"
       schema_transformations:
         title: Schema Transformations
         description: A list of transformations to be applied to the schema.
@@ -3369,7 +3340,6 @@ definitions:
       extractor:
         anyOf:
           - "$ref": "#/definitions/DpathExtractor"
-          - "$ref": "#/definitions/CombinedExtractor"
           - "$ref": "#/definitions/KeyValueExtractor"
           - "$ref": "#/definitions/CustomRecordExtractor"
       record_filter:
@@ -4050,9 +4020,6 @@ definitions:
         title: Value Type
         description: The expected data type of the value. If omitted, the type will be inferred from the value provided.
         "$ref": "#/definitions/ValueType"
-      create_or_update:
-        type: boolean
-        default: false
       $parameters:
         type: object
         additionalProperties: true
@@ -4104,10 +4071,6 @@ definitions:
           - ["data"]
           - ["data", "streams"]
           - ["data", "{{ parameters.name }}"]
-      default_values:
-        title: Default Values
-        description: placeholder
-        type: array
       $parameters:
         type: object
         additionalProperties: true
@@ -4119,11 +4082,7 @@ definitions:
         type: string
         enum: [ConfigComponentsResolver]
       stream_config:
-        anyOf:
-          - type: array
-            items:
-              "$ref": "#/definitions/StreamConfig"
-          - "$ref": "#/definitions/StreamConfig"
+        "$ref": "#/definitions/StreamConfig"
       components_mapping:
         type: array
         items:

airbyte_cdk/sources/declarative/extractors/__init__.py

@@ -2,7 +2,6 @@
 # Copyright (c) 2023 Airbyte, Inc., all rights reserved.
 #
 
-from airbyte_cdk.sources.declarative.extractors.combined_extractor import CombinedExtractor
 from airbyte_cdk.sources.declarative.extractors.dpath_extractor import DpathExtractor
 from airbyte_cdk.sources.declarative.extractors.http_selector import HttpSelector
 from airbyte_cdk.sources.declarative.extractors.key_value_extractor import KeyValueExtractor
@@ -21,5 +20,4 @@
     "RecordSelector",
     "ResponseToFileExtractor",
     "KeyValueExtractor",
-    "CombinedExtractor",
 ]

airbyte_cdk/sources/declarative/extractors/combined_extractor.py

@@ -262,7 +262,9 @@ def streams(self, config: Mapping[str, Any]) -> List[Stream]:
             }
         )
 
-        stream_configs = self._stream_configs(self._source_config) + self.dynamic_streams
+        stream_configs = self._stream_configs(self._source_config) + self._dynamic_stream_configs(
+            self._source_config, config
+        )
 
         api_budget_model = self._source_config.get("api_budget")
         if api_budget_model: