pass top level params to PropertiesFromEndpoint requester

Author: darynaishchenko

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

@@ -2758,6 +2758,9 @@ def create_parent_stream_config(
     def create_properties_from_endpoint(
         self, model: PropertiesFromEndpointModel, config: Config, **kwargs: Any
     ) -> PropertiesFromEndpoint:
+        parameters = model.retriever.requester.parameters or {}
+        parameters.update(model.parameters or {})
+        model.retriever.requester.parameters = parameters
         retriever = self._create_component_from_model(
             model=model.retriever,
             config=config,
@@ -2808,8 +2811,12 @@ def create_query_properties(
         if isinstance(model.property_list, list):
             property_list = model.property_list
         else:
+            property_list_model = model.property_list
+            parameters = property_list_model.parameters if property_list_model.parameters is not None else {}
+            parameters.update(model.parameters or {})
+            property_list_model.parameters = parameters
             property_list = self._create_component_from_model(
-                model=model.property_list, config=config, **kwargs
+                model=property_list_model, config=config, **kwargs
             )
 
         property_chunking = (
@@ -3046,8 +3053,12 @@ def _get_url() -> str:
                 )
 
             if len(query_properties_definitions) == 1:
+                query_properties_definition_model = query_properties_definitions[0]
+                parameters = query_properties_definition_model.parameters if query_properties_definition_model.parameters is not None else {}
+                parameters.update(model.parameters or {})
+                query_properties_definition_model.parameters = parameters
                 query_properties = self._create_component_from_model(
-                    model=query_properties_definitions[0], config=config
+                    model=query_properties_definition_model, config=config
                 )
         elif (
             hasattr(model.requester, "fetch_properties_from_endpoint")