We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a4d853b commit 321a62eCopy full SHA for 321a62e
airbyte_cdk/sources/declarative/retrievers/simple_retriever.py
@@ -670,6 +670,7 @@ def _fetch_next_page(
670
stream_slice: StreamSlice,
671
next_page_token: Optional[Mapping[str, Any]] = None,
672
) -> Optional[requests.Response]:
673
+ is_dynamic_schema_call = (self.name == "dynamic_properties")
674
return self.requester.send_request(
675
path=self._paginator_path(
676
next_page_token=next_page_token,
@@ -704,6 +705,7 @@ def _fetch_next_page(
704
705
f"Stream '{self.name}' request",
706
f"Request performed in order to extract records for stream '{self.name}'",
707
self.name,
708
+ is_auxiliary=is_dynamic_schema_call # Mark schema discovery calls as auxiliary for cleaner logs
709
),
710
)
711
0 commit comments