From 44a1440d499692815f2ab90187bb7bbddc62c78c Mon Sep 17 00:00:00 2001 From: Catherine Noll Date: Thu, 1 Dec 2022 15:52:20 -0500 Subject: [PATCH] Include http method in `SimpleRetriever` log message for requests (#19964) * Add http method to `SimpleRetriever` log message on request * Update setup.py (bump version to 0.11.2) * Update CHANGELOG.md --- airbyte-cdk/python/CHANGELOG.md | 3 +++ .../sources/declarative/retrievers/simple_retriever.py | 2 +- airbyte-cdk/python/setup.py | 2 +- 3 files changed, 5 insertions(+), 2 deletions(-) diff --git a/airbyte-cdk/python/CHANGELOG.md b/airbyte-cdk/python/CHANGELOG.md index b3cebc199db6ed..f69a6b8f504623 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 867eb8dd837fb8..f25eaf49d0282d 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 e6e8dfd43b24f8..1ed8be21dbb17c 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",