From 6b0097b5f8ea51d11b666787977b8856c09d4fe4 Mon Sep 17 00:00:00 2001 From: Cyprien Barbault Date: Tue, 3 Jan 2023 16:56:49 +0100 Subject: [PATCH 1/3] added utf-8 encoding --- .../connectors/source-marketo/source_marketo/source.py | 1 + 1 file changed, 1 insertion(+) diff --git a/airbyte-integrations/connectors/source-marketo/source_marketo/source.py b/airbyte-integrations/connectors/source-marketo/source_marketo/source.py index aef902242d43..1723f9f15b44 100644 --- a/airbyte-integrations/connectors/source-marketo/source_marketo/source.py +++ b/airbyte-integrations/connectors/source-marketo/source_marketo/source.py @@ -226,6 +226,7 @@ def parse_response(self, response: requests.Response, **kwargs) -> Iterable[Mapp default_prop = {"type": ["null", "string"]} schema = self.get_json_schema()["properties"] + response.encoding = 'utf-8' reader = csv.DictReader(response.iter_lines(chunk_size=1024, decode_unicode=True)) for record in reader: From f9d570e9a7ee8b50b2e143827164be6ff723c4ff Mon Sep 17 00:00:00 2001 From: Vincent Koc Date: Thu, 19 Jan 2023 18:52:45 +1100 Subject: [PATCH 2/3] chore: bump version --- airbyte-integrations/connectors/source-marketo/Dockerfile | 2 +- docs/integrations/sources/marketo.md | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/airbyte-integrations/connectors/source-marketo/Dockerfile b/airbyte-integrations/connectors/source-marketo/Dockerfile index 2535bd7ba33d..7debb6366db5 100644 --- a/airbyte-integrations/connectors/source-marketo/Dockerfile +++ b/airbyte-integrations/connectors/source-marketo/Dockerfile @@ -34,5 +34,5 @@ COPY source_marketo ./source_marketo ENV AIRBYTE_ENTRYPOINT "python /airbyte/integration_code/main.py" ENTRYPOINT ["python", "/airbyte/integration_code/main.py"] -LABEL io.airbyte.version=0.1.11 +LABEL io.airbyte.version=0.1.12 LABEL io.airbyte.name=airbyte/source-marketo diff --git a/docs/integrations/sources/marketo.md b/docs/integrations/sources/marketo.md index 85c544b2497a..668a9da1b07c 100644 --- a/docs/integrations/sources/marketo.md +++ b/docs/integrations/sources/marketo.md @@ -106,6 +106,7 @@ If the 50,000 limit is too stringent, contact Marketo support for a quota increa | Version | Date | Pull Request | Subject | |:---------|:-----------|:---------------------------------------------------------|:----------------------------------------------------------------------------------------------| +| `0.1.12` | 2023-01-19 | [20973](https://github.com/airbytehq/airbyte/pull/20973) | Fix encoding error | | `0.1.11` | 2022-09-30 | [17445](https://github.com/airbytehq/airbyte/pull/17445) | Do not use temporary files for memory optimization | | `0.1.10` | 2022-09-30 | [17445](https://github.com/airbytehq/airbyte/pull/17445) | Optimize memory consumption | | `0.1.9` | 2022-09-28 | [17304](https://github.com/airbytehq/airbyte/pull/17304) | Migrate to per-stream sate. | From c39386ec614a700a0af2642a754e944524a92f7d Mon Sep 17 00:00:00 2001 From: Octavia Squidington III Date: Thu, 19 Jan 2023 10:36:08 +0000 Subject: [PATCH 3/3] auto-bump connector version --- .../init/src/main/resources/seed/source_definitions.yaml | 2 +- airbyte-config/init/src/main/resources/seed/source_specs.yaml | 2 +- .../connectors/source-marketo/source_marketo/source.py | 2 +- 3 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 e7dfad1c3c12..ee1c215f63ee 100644 --- a/airbyte-config/init/src/main/resources/seed/source_definitions.yaml +++ b/airbyte-config/init/src/main/resources/seed/source_definitions.yaml @@ -1003,7 +1003,7 @@ - name: Marketo sourceDefinitionId: 9e0556f4-69df-4522-a3fb-03264d36b348 dockerRepository: airbyte/source-marketo - dockerImageTag: 0.1.11 + dockerImageTag: 0.1.12 documentationUrl: https://docs.airbyte.com/integrations/sources/marketo icon: marketo.svg sourceType: api 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 dc9f71b621a7..4507bef2615c 100644 --- a/airbyte-config/init/src/main/resources/seed/source_specs.yaml +++ b/airbyte-config/init/src/main/resources/seed/source_specs.yaml @@ -8023,7 +8023,7 @@ supportsNormalization: false supportsDBT: false supported_destination_sync_modes: [] -- dockerImage: "airbyte/source-marketo:0.1.11" +- dockerImage: "airbyte/source-marketo:0.1.12" spec: documentationUrl: "https://docs.airbyte.com/integrations/sources/marketo" connectionSpecification: diff --git a/airbyte-integrations/connectors/source-marketo/source_marketo/source.py b/airbyte-integrations/connectors/source-marketo/source_marketo/source.py index 1723f9f15b44..b8f48e9fc2e3 100644 --- a/airbyte-integrations/connectors/source-marketo/source_marketo/source.py +++ b/airbyte-integrations/connectors/source-marketo/source_marketo/source.py @@ -226,7 +226,7 @@ def parse_response(self, response: requests.Response, **kwargs) -> Iterable[Mapp default_prop = {"type": ["null", "string"]} schema = self.get_json_schema()["properties"] - response.encoding = 'utf-8' + response.encoding = "utf-8" reader = csv.DictReader(response.iter_lines(chunk_size=1024, decode_unicode=True)) for record in reader: