From 7d1f1e69f674d5b317e25bbb5437a2d01e2b6a8e Mon Sep 17 00:00:00 2001 From: Oleksandr Bazarnov Date: Thu, 28 Apr 2022 14:05:13 +0300 Subject: [PATCH] updated after review --- .../init/src/main/resources/seed/source_definitions.yaml | 2 +- .../connectors/source-amplitude/source_amplitude/api.py | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/airbyte-config/init/src/main/resources/seed/source_definitions.yaml b/airbyte-config/init/src/main/resources/seed/source_definitions.yaml index 1899b7867f3aa4..d642115f0f67c4 100644 --- a/airbyte-config/init/src/main/resources/seed/source_definitions.yaml +++ b/airbyte-config/init/src/main/resources/seed/source_definitions.yaml @@ -35,7 +35,7 @@ - name: Amplitude sourceDefinitionId: fa9f58c6-2d03-4237-aaa4-07d75e0c1396 dockerRepository: airbyte/source-amplitude - dockerImageTag: 0.1.5 + dockerImageTag: 0.1.4 documentationUrl: https://docs.airbyte.io/integrations/sources/amplitude icon: amplitude.svg sourceType: api diff --git a/airbyte-integrations/connectors/source-amplitude/source_amplitude/api.py b/airbyte-integrations/connectors/source-amplitude/source_amplitude/api.py index b6959ba423ccb4..0d2908608a5e35 100644 --- a/airbyte-integrations/connectors/source-amplitude/source_amplitude/api.py +++ b/airbyte-integrations/connectors/source-amplitude/source_amplitude/api.py @@ -30,7 +30,7 @@ def next_page_token(self, response: requests.Response) -> Optional[Mapping[str, def parse_response(self, response: requests.Response, **kwargs) -> Iterable[Mapping]: status = response.status_code - if status in list(HTTP_ERROR_CODES.keys()): + if status in HTTP_ERROR_CODES.keys(): error_msg_from_status(status) yield from [] else: @@ -167,7 +167,7 @@ def read_records( yield from super().read_records(sync_mode, cursor_field, stream_slice, stream_state) except requests.exceptions.HTTPError as error: status = error.response.status_code - if status in list(HTTP_ERROR_CODES.keys()): + if status in HTTP_ERROR_CODES.keys(): error_msg_from_status(status) yield from [] else: