Skip to content

Commit

Permalink
馃悰 Source RD Station Marketing: Fix stream analytics conversions (#18826)
Browse files Browse the repository at this point in the history
* 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 <octavia-squidington-iii@users.noreply.github.com>
  • Loading branch information
sarafonseca-123 and octavia-squidington-iii committed Dec 5, 2022
1 parent 34e85e3 commit c471be2
Show file tree
Hide file tree
Showing 5 changed files with 5 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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
Original file line number Diff line number Diff line change
Expand Up @@ -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):
"""
Expand Down
3 changes: 2 additions & 1 deletion docs/integrations/sources/rd-station-marketing.md
Original file line number Diff line number Diff line change
Expand Up @@ -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 |

0 comments on commit c471be2

Please sign in to comment.