Skip to content

Commit 02f811d

Browse files
author
Anton Karpets
authored
✨Source Klaviyo: add new streams (#37370)
1 parent 0ed20e5 commit 02f811d

19 files changed

+702
-303
lines changed

‎airbyte-integrations/connectors/source-klaviyo/acceptance-test-config.yml

+1
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@ acceptance_tests:
2525
configured_catalog_path: integration_tests/configured_catalog.json
2626
future_state:
2727
future_state_path: integration_tests/abnormal_state.json
28+
skip_comprehensive_incremental_tests: true
2829
spec:
2930
tests:
3031
- spec_path: source_klaviyo/spec.json

‎airbyte-integrations/connectors/source-klaviyo/integration_tests/abnormal_state.json

+140
Original file line numberDiff line numberDiff line change
@@ -57,6 +57,132 @@
5757
}
5858
}
5959
},
60+
{
61+
"type": "STREAM",
62+
"stream": {
63+
"stream_state": {
64+
"states": [
65+
{
66+
"partition": { "id": "R2p3ry", "parent_slice": {} },
67+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
68+
},
69+
{
70+
"partition": { "id": "R4ZhCr", "parent_slice": {} },
71+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
72+
},
73+
{
74+
"partition": { "id": "RPfQMj", "parent_slice": {} },
75+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
76+
},
77+
{
78+
"partition": { "id": "RgS4w6", "parent_slice": {} },
79+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
80+
},
81+
{
82+
"partition": { "id": "RnsiHB", "parent_slice": {} },
83+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
84+
},
85+
{
86+
"partition": { "id": "RwKPyg", "parent_slice": {} },
87+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
88+
},
89+
{
90+
"partition": { "id": "S7aBY2", "parent_slice": {} },
91+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
92+
},
93+
{
94+
"partition": { "id": "S8nmQ9", "parent_slice": {} },
95+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
96+
},
97+
{
98+
"partition": { "id": "SBYgiK", "parent_slice": {} },
99+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
100+
},
101+
{
102+
"partition": { "id": "SYEFFb", "parent_slice": {} },
103+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
104+
},
105+
{
106+
"partition": { "id": "Seq8wh", "parent_slice": {} },
107+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
108+
},
109+
{
110+
"partition": { "id": "SmDD4y", "parent_slice": {} },
111+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
112+
},
113+
{
114+
"partition": { "id": "TDGJsj", "parent_slice": {} },
115+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
116+
},
117+
{
118+
"partition": { "id": "TWcKFn", "parent_slice": {} },
119+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
120+
},
121+
{
122+
"partition": { "id": "TaSce6", "parent_slice": {} },
123+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
124+
},
125+
{
126+
"partition": { "id": "TjbH4K", "parent_slice": {} },
127+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
128+
},
129+
{
130+
"partition": { "id": "TpNXq9", "parent_slice": {} },
131+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
132+
},
133+
{
134+
"partition": { "id": "UeGLUr", "parent_slice": {} },
135+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
136+
},
137+
{
138+
"partition": { "id": "UzdNhZ", "parent_slice": {} },
139+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
140+
},
141+
{
142+
"partition": { "id": "VDZnQt", "parent_slice": {} },
143+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
144+
},
145+
{
146+
"partition": { "id": "VJCDbR", "parent_slice": {} },
147+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
148+
},
149+
{
150+
"partition": { "id": "VmvmBq", "parent_slice": {} },
151+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
152+
},
153+
{
154+
"partition": { "id": "WBxsQE", "parent_slice": {} },
155+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
156+
},
157+
{
158+
"partition": { "id": "WJLXnV", "parent_slice": {} },
159+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
160+
},
161+
{
162+
"partition": { "id": "X7UeXn", "parent_slice": {} },
163+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
164+
},
165+
{
166+
"partition": { "id": "XGj3p8", "parent_slice": {} },
167+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
168+
},
169+
{
170+
"partition": { "id": "XUbNgM", "parent_slice": {} },
171+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
172+
},
173+
{
174+
"partition": { "id": "XpP2a5", "parent_slice": {} },
175+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
176+
},
177+
{
178+
"partition": { "id": "Ya5ziX", "parent_slice": {} },
179+
"cursor": { "updated": "2120-10-10T00:00:00+00:00" }
180+
}
181+
]
182+
},
183+
"stream_descriptor": { "name": "lists_detailed" }
184+
}
185+
},
60186
{
61187
"type": "STREAM",
62188
"stream": {
@@ -71,6 +197,20 @@
71197
}
72198
}
73199
},
200+
{
201+
"type": "STREAM",
202+
"stream": {
203+
"stream_state": {
204+
"updated_at": "2120-10-10T00:00:00+00:00",
205+
"archived": {
206+
"updated_at": "2120-10-10T00:00:00+00:00"
207+
}
208+
},
209+
"stream_descriptor": {
210+
"name": "campaigns_detailed"
211+
}
212+
}
213+
},
74214
{
75215
"type": "STREAM",
76216
"stream": {

‎airbyte-integrations/connectors/source-klaviyo/integration_tests/configured_catalog.json

+30
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,21 @@
1515
"destination_sync_mode": "append",
1616
"primary_key": [["id"]]
1717
},
18+
{
19+
"stream": {
20+
"name": "campaigns_detailed",
21+
"json_schema": {},
22+
"supported_sync_modes": ["full_refresh", "incremental"],
23+
"source_defined_cursor": true,
24+
"default_cursor_field": ["updated_at"],
25+
"source_defined_primary_key": [["id"]],
26+
"namespace": null
27+
},
28+
"sync_mode": "incremental",
29+
"cursor_field": ["updated_at"],
30+
"destination_sync_mode": "append",
31+
"primary_key": [["id"]]
32+
},
1833
{
1934
"stream": {
2035
"name": "profiles",
@@ -75,6 +90,21 @@
7590
"destination_sync_mode": "append",
7691
"primary_key": [["id"]]
7792
},
93+
{
94+
"stream": {
95+
"name": "lists_detailed",
96+
"json_schema": {},
97+
"supported_sync_modes": ["full_refresh", "incremental"],
98+
"source_defined_cursor": true,
99+
"default_cursor_field": ["updated"],
100+
"source_defined_primary_key": [["id"]],
101+
"namespace": null
102+
},
103+
"sync_mode": "incremental",
104+
"cursor_field": ["updated"],
105+
"destination_sync_mode": "append",
106+
"primary_key": [["id"]]
107+
},
78108
{
79109
"stream": {
80110
"name": "flows",

0 commit comments

Comments
 (0)