diff --git a/airbyte-cdk/python/CHANGELOG.md b/airbyte-cdk/python/CHANGELOG.md index b3cebc199db6e..f69a6b8f50462 100644 --- a/airbyte-cdk/python/CHANGELOG.md +++ b/airbyte-cdk/python/CHANGELOG.md @@ -1,5 +1,8 @@ # Changelog +## 0.11.2 +Low-code: Include the HTTP method used by the request in logging output of the `airbyte-cdk` + ## 0.11.1 Low-code: Fix the component manifest schema to and validate check instead of checker diff --git a/airbyte-cdk/python/airbyte_cdk/sources/declarative/retrievers/simple_retriever.py b/airbyte-cdk/python/airbyte_cdk/sources/declarative/retrievers/simple_retriever.py index 867eb8dd837fb..f25eaf49d0282 100644 --- a/airbyte-cdk/python/airbyte_cdk/sources/declarative/retrievers/simple_retriever.py +++ b/airbyte-cdk/python/airbyte_cdk/sources/declarative/retrievers/simple_retriever.py @@ -413,7 +413,7 @@ def parse_records_and_emit_request_and_responses(self, request, response, stream def _create_trace_message_from_request(self, request: requests.PreparedRequest): # FIXME: this should return some sort of trace message - request_dict = {"url": request.url, "headers": dict(request.headers), "body": request.body} + request_dict = {"url": request.url, "http_method": request.method, "headers": dict(request.headers), "body": request.body} log_message = filter_secrets(f"request:{json.dumps(request_dict)}") return AirbyteMessage(type=MessageType.LOG, log=AirbyteLogMessage(level=Level.INFO, message=log_message)) diff --git a/airbyte-cdk/python/setup.py b/airbyte-cdk/python/setup.py index e6e8dfd43b24f..1ed8be21dbb17 100644 --- a/airbyte-cdk/python/setup.py +++ b/airbyte-cdk/python/setup.py @@ -15,7 +15,7 @@ setup( name="airbyte-cdk", - version="0.11.1", + version="0.11.2", description="A framework for writing Airbyte Connectors.", long_description=README, long_description_content_type="text/markdown",