Add logger to dynamic schema loader

Author: lazebnyi

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

@@ -23,7 +23,7 @@
     get_origin,
     get_type_hints,
 )
-
+from requests import  Response
 from isodate import parse_duration
 from pydantic.v1 import BaseModel
 
@@ -2375,16 +2375,22 @@ def create_dynamic_schema_loader(
                 schema_transformations.append(
                     self._create_component_from_model(model=transformation_model, config=config)
                 )
-
+        name = "dynamic_properties"
         retriever = self._create_component_from_model(
             model=model.retriever,
             config=config,
-            name="dynamic_properties",
+            name=name,
             primary_key=None,
             stream_slicer=combined_slicers,
             transformations=[],
-            enable_logs=False,
             use_cache=True,
+            log_formatter=(lambda response: format_http_message(
+                    response,
+                    f"Schema loader '{name}' request",
+                    f"Request performed in order to extract schema.",
+                    name,
+                    is_auxiliary=True,
+                )),
         )
         schema_type_identifier = self._create_component_from_model(
             model.schema_type_identifier, config=config, parameters=model.parameters or {}
@@ -2971,7 +2977,7 @@ def create_simple_retriever(
             ]
         ] = None,
         use_cache: Optional[bool] = None,
-        enable_logs: bool = True,
+        log_formatter: Optional[Callable[[Response], Any]] = None,
         **kwargs: Any,
     ) -> SimpleRetriever:
         def _get_url() -> str:
@@ -3153,7 +3159,7 @@ def _get_url() -> str:
                     f"Stream '{name}' request",
                     f"Request performed in order to extract records for stream '{name}'",
                     name,
-                )) if enable_logs else None,
+                )) if not log_formatter else log_formatter,
                 parameters=model.parameters or {},
             )
         return SimpleRetriever(