From c471be2913b2b9ce5a3dc75361a96282f5a51d02 Mon Sep 17 00:00:00 2001 From: sarafonseca Date: Mon, 5 Dec 2022 13:48:38 -0300 Subject: [PATCH] =?UTF-8?q?=F0=9F=90=9B=20Source=20RD=20Station=20Marketin?= =?UTF-8?q?g:=20Fix=20stream=20analytics=20conversions=20(#18826)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit * Fix stream analytics conversions on RD Station Marketing * update connector's version * Fix PR number on changelog * auto-bump connector version Co-authored-by: Octavia Squidington III --- .../init/src/main/resources/seed/source_definitions.yaml | 2 +- airbyte-config/init/src/main/resources/seed/source_specs.yaml | 2 +- .../connectors/source-rd-station-marketing/Dockerfile | 2 +- .../source_rd_station_marketing/streams.py | 4 ---- docs/integrations/sources/rd-station-marketing.md | 3 ++- 5 files changed, 5 insertions(+), 8 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 68404cd8996f9a..17c59e8e583d50 100644 --- a/airbyte-config/init/src/main/resources/seed/source_definitions.yaml +++ b/airbyte-config/init/src/main/resources/seed/source_definitions.yaml @@ -1378,7 +1378,7 @@ - name: RD Station Marketing sourceDefinitionId: fb141f29-be2a-450b-a4f2-2cd203a00f84 dockerRepository: airbyte/source-rd-station-marketing - dockerImageTag: 0.1.0 + dockerImageTag: 0.1.1 documentationUrl: https://docs.airbyte.com/integrations/sources/rd-station-marketing sourceType: api releaseStage: alpha diff --git a/airbyte-config/init/src/main/resources/seed/source_specs.yaml b/airbyte-config/init/src/main/resources/seed/source_specs.yaml index be5f9e0574c6c1..b39358ad4248ce 100644 --- a/airbyte-config/init/src/main/resources/seed/source_specs.yaml +++ b/airbyte-config/init/src/main/resources/seed/source_specs.yaml @@ -12392,7 +12392,7 @@ path_in_connector_config: - "credentials" - "client_secret" -- dockerImage: "airbyte/source-rd-station-marketing:0.1.0" +- dockerImage: "airbyte/source-rd-station-marketing:0.1.1" spec: documentationUrl: "https://docs.airbyte.io/integrations/sources/rd-station-marketing" connectionSpecification: diff --git a/airbyte-integrations/connectors/source-rd-station-marketing/Dockerfile b/airbyte-integrations/connectors/source-rd-station-marketing/Dockerfile index 327eabb2010acf..94dfec89b0f164 100644 --- a/airbyte-integrations/connectors/source-rd-station-marketing/Dockerfile +++ b/airbyte-integrations/connectors/source-rd-station-marketing/Dockerfile @@ -34,5 +34,5 @@ COPY source_rd_station_marketing ./source_rd_station_marketing ENV AIRBYTE_ENTRYPOINT "python /airbyte/integration_code/main.py" ENTRYPOINT ["python", "/airbyte/integration_code/main.py"] -LABEL io.airbyte.version=0.1.0 +LABEL io.airbyte.version=0.1.1 LABEL io.airbyte.name=airbyte/source-rd-station-marketing diff --git a/airbyte-integrations/connectors/source-rd-station-marketing/source_rd_station_marketing/streams.py b/airbyte-integrations/connectors/source-rd-station-marketing/source_rd_station_marketing/streams.py index 25bca07992802a..97b82b251d0234 100755 --- a/airbyte-integrations/connectors/source-rd-station-marketing/source_rd_station_marketing/streams.py +++ b/airbyte-integrations/connectors/source-rd-station-marketing/source_rd_station_marketing/streams.py @@ -94,10 +94,6 @@ class AnalyticsConversions(IncrementalRDStationMarketingStream): cursor_field = "asset_updated_at" primary_key = "asset_id" - def parse_response(self, response: requests.Response, **kwargs) -> Iterable[Mapping]: - records = response.json().get(self.data_field)[0].get(self.data_field) - yield from records - class AnalyticsEmails(IncrementalRDStationMarketingStream): """ diff --git a/docs/integrations/sources/rd-station-marketing.md b/docs/integrations/sources/rd-station-marketing.md index 989d4e20549914..193192d0eb3397 100644 --- a/docs/integrations/sources/rd-station-marketing.md +++ b/docs/integrations/sources/rd-station-marketing.md @@ -41,4 +41,5 @@ Each endpoint has its own performance limitations, which also consider the accou | Version | Date | Pull Request | Subject | | :------ | :--------- | :------------------------------------------------------- | :-------------------------------------------------------------- | -| 0.1.0 | 2022-10-23 | [18348](https://github.com/airbytehq/airbyte/pull/18348) | Initial Release | +| 0.1.1 | 2022-11-01 | [18826](https://github.com/airbytehq/airbyte/pull/18826) | Fix stream analytics_conversions | +| 0.1.0 | 2022-10-23 | [18348](https://github.com/airbytehq/airbyte/pull/18348) | Initial Release |