Skip to content

Commit 4e3189e

Browse files
roman-yermilov-glxiaohansong
authored andcommitted
Source Klaviyo: added transform config for profile stream (#35336)
1 parent 57209fd commit 4e3189e

File tree

3 files changed

+6
-2
lines changed

3 files changed

+6
-2
lines changed

airbyte-integrations/connectors/source-klaviyo/metadata.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ data:
88
definitionId: 95e8cffd-b8c4-4039-968e-d32fb4a69bde
99
connectorBuildOptions:
1010
baseImage: docker.io/airbyte/python-connector-base:1.1.0@sha256:bd98f6505c6764b1b5f99d3aedc23dfc9e9af631a62533f60eb32b1d3dbab20c
11-
dockerImageTag: 2.1.2
11+
dockerImageTag: 2.1.3
1212
dockerRepository: airbyte/source-klaviyo
1313
githubIssueLabel: source-klaviyo
1414
icon: klaviyo.svg

airbyte-integrations/connectors/source-klaviyo/source_klaviyo/streams.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@
1212
from airbyte_cdk.sources.streams.availability_strategy import AvailabilityStrategy
1313
from airbyte_cdk.sources.streams.core import StreamData
1414
from airbyte_cdk.sources.streams.http import HttpStream
15+
from airbyte_cdk.sources.utils.transform import TransformConfig, TypeTransformer
1516

1617
from .availability_strategy import KlaviyoAvailabilityStrategy
1718
from .exceptions import KlaviyoBackoffError
@@ -242,6 +243,8 @@ def read_records(
242243
class Profiles(IncrementalKlaviyoStream):
243244
"""Docs: https://developers.klaviyo.com/en/v2023-02-22/reference/get_profiles"""
244245

246+
transformer: TypeTransformer = TypeTransformer(TransformConfig.DefaultSchemaNormalization)
247+
245248
cursor_field = "updated"
246249
api_revision = "2023-02-22"
247250
page_size = 100

docs/integrations/sources/klaviyo.md

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,8 @@ The Klaviyo connector should not run into Klaviyo API limitations under normal u
6363

6464
| Version | Date | Pull Request | Subject |
6565
| :------- | :--------- | :--------------------------------------------------------- | :---------------------------------------------------------------------------------------------------------------------------- |
66-
| 2.1.2 | 2024-02-09 | [35088](https://github.com/airbytehq/airbyte/pull/35088) | Manage dependencies with Poetry. |
66+
| `2.1.3` | 2024-02-15 | [35336](https://github.com/airbytehq/airbyte/pull/35336) | Added type transformer for the `profiles` stream. |
67+
| `2.1.2` | 2024-02-09 | [35088](https://github.com/airbytehq/airbyte/pull/35088) | Manage dependencies with Poetry. |
6768
| `2.1.1` | 2024-02-07 | [34998](https://github.com/airbytehq/airbyte/pull/34998) | Add missing fields to stream schemas |
6869
| `2.1.0` | 2023-12-07 | [33237](https://github.com/airbytehq/airbyte/pull/33237) | Continue syncing streams even when one of the stream fails |
6970
| `2.0.2` | 2023-12-05 | [33099](https://github.com/airbytehq/airbyte/pull/33099) | Fix filtering for archived records stream |

0 commit comments

Comments
 (0)