Skip to content

Commit 1e1b8e5

Browse files
lazebnyigirarda
authored and
xiaohansong
committed
refactor[source-snapchat-marketing]: migrate to low-code (#39507)
Co-authored-by: Alexandre Girard <[email protected]>
1 parent ef4d48d commit 1e1b8e5

24 files changed

+4986
-2320
lines changed

‎airbyte-integrations/connectors/source-snapchat-marketing/.coveragerc

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
[run]
2+
omit =
3+
source_snapchat_marketing/run.py

‎airbyte-integrations/connectors/source-snapchat-marketing/integration_tests/abnormal_state.json

Lines changed: 195 additions & 28 deletions
Original file line numberDiff line numberDiff line change
@@ -2,77 +2,244 @@
22
{
33
"type": "STREAM",
44
"stream": {
5-
"stream_state": {
6-
"updated_at": "2221-01-01T00:00:00Z"
7-
},
85
"stream_descriptor": {
9-
"name": "adaccounts"
6+
"name": "adaccounts",
7+
"namespace": null
8+
},
9+
"stream_state": {
10+
"states": [
11+
{
12+
"partition": {
13+
"organization_id": "7f064d90-52a1-42db-b25b-7539e663e926",
14+
"parent_slice": {}
15+
},
16+
"cursor": {
17+
"updated_at": "2221-01-01T00:00:00.000Z"
18+
}
19+
}
20+
]
1021
}
1122
}
1223
},
1324
{
1425
"type": "STREAM",
1526
"stream": {
16-
"stream_state": {
17-
"updated_at": "2221-01-01T00:00:00Z"
18-
},
1927
"stream_descriptor": {
20-
"name": "creatives"
28+
"name": "creatives",
29+
"namespace": null
30+
},
31+
"stream_state": {
32+
"states": [
33+
{
34+
"partition": {
35+
"adaccount_id": "04214c00-3aa5-4123-b5c8-363c32c40e42",
36+
"parent_slice": {
37+
"organization_id": "7f064d90-52a1-42db-b25b-7539e663e926",
38+
"parent_slice": {}
39+
}
40+
},
41+
"cursor": {
42+
"updated_at": "2221-01-01T00:00:00.000Z"
43+
}
44+
},
45+
{
46+
"partition": {
47+
"adaccount_id": "e4cd371b-8de8-4011-a8d2-860fe77c09e1",
48+
"parent_slice": {
49+
"organization_id": "7f064d90-52a1-42db-b25b-7539e663e926",
50+
"parent_slice": {}
51+
}
52+
},
53+
"cursor": {
54+
"updated_at": "2221-01-01T00:00:00.000Z"
55+
}
56+
}
57+
]
2158
}
2259
}
2360
},
2461
{
2562
"type": "STREAM",
2663
"stream": {
27-
"stream_state": {
28-
"updated_at": "2221-01-01T00:00:00Z"
29-
},
3064
"stream_descriptor": {
31-
"name": "media"
65+
"name": "media",
66+
"namespace": null
67+
},
68+
"stream_state": {
69+
"states": [
70+
{
71+
"partition": {
72+
"adaccount_id": "04214c00-3aa5-4123-b5c8-363c32c40e42",
73+
"parent_slice": {
74+
"organization_id": "7f064d90-52a1-42db-b25b-7539e663e926",
75+
"parent_slice": {}
76+
}
77+
},
78+
"cursor": {
79+
"updated_at": "2221-01-01T00:00:00.000Z"
80+
}
81+
},
82+
{
83+
"partition": {
84+
"adaccount_id": "e4cd371b-8de8-4011-a8d2-860fe77c09e1",
85+
"parent_slice": {
86+
"organization_id": "7f064d90-52a1-42db-b25b-7539e663e926",
87+
"parent_slice": {}
88+
}
89+
},
90+
"cursor": {
91+
"updated_at": "2221-01-01T00:00:00.000Z"
92+
}
93+
}
94+
]
3295
}
3396
}
3497
},
3598
{
3699
"type": "STREAM",
37100
"stream": {
38-
"stream_state": {
39-
"updated_at": "2221-01-01T00:00:00Z"
40-
},
41101
"stream_descriptor": {
42-
"name": "campaigns"
102+
"name": "campaigns",
103+
"namespace": null
104+
},
105+
"stream_state": {
106+
"states": [
107+
{
108+
"partition": {
109+
"adaccount_id": "04214c00-3aa5-4123-b5c8-363c32c40e42",
110+
"parent_slice": {
111+
"organization_id": "7f064d90-52a1-42db-b25b-7539e663e926",
112+
"parent_slice": {}
113+
}
114+
},
115+
"cursor": {
116+
"updated_at": "2221-01-01T00:00:00.000Z"
117+
}
118+
},
119+
{
120+
"partition": {
121+
"adaccount_id": "e4cd371b-8de8-4011-a8d2-860fe77c09e1",
122+
"parent_slice": {
123+
"organization_id": "7f064d90-52a1-42db-b25b-7539e663e926",
124+
"parent_slice": {}
125+
}
126+
},
127+
"cursor": {
128+
"updated_at": "2221-01-01T00:00:00.000Z"
129+
}
130+
}
131+
]
43132
}
44133
}
45134
},
46135
{
47136
"type": "STREAM",
48137
"stream": {
49-
"stream_state": {
50-
"updated_at": "2221-01-01T00:00:00Z"
51-
},
52138
"stream_descriptor": {
53-
"name": "ads"
139+
"name": "ads",
140+
"namespace": null
141+
},
142+
"stream_state": {
143+
"states": [
144+
{
145+
"partition": {
146+
"adaccount_id": "04214c00-3aa5-4123-b5c8-363c32c40e42",
147+
"parent_slice": {
148+
"organization_id": "7f064d90-52a1-42db-b25b-7539e663e926",
149+
"parent_slice": {}
150+
}
151+
},
152+
"cursor": {
153+
"updated_at": "2221-01-01T00:00:00.000Z"
154+
}
155+
},
156+
{
157+
"partition": {
158+
"adaccount_id": "e4cd371b-8de8-4011-a8d2-860fe77c09e1",
159+
"parent_slice": {
160+
"organization_id": "7f064d90-52a1-42db-b25b-7539e663e926",
161+
"parent_slice": {}
162+
}
163+
},
164+
"cursor": {
165+
"updated_at": "2221-01-01T00:00:00.000Z"
166+
}
167+
}
168+
]
54169
}
55170
}
56171
},
57172
{
58173
"type": "STREAM",
59174
"stream": {
60-
"stream_state": {
61-
"updated_at": "2221-01-01T00:00:00Z"
62-
},
63175
"stream_descriptor": {
64-
"name": "adsquads"
176+
"name": "adsquads",
177+
"namespace": null
178+
},
179+
"stream_state": {
180+
"states": [
181+
{
182+
"partition": {
183+
"adaccount_id": "04214c00-3aa5-4123-b5c8-363c32c40e42",
184+
"parent_slice": {
185+
"organization_id": "7f064d90-52a1-42db-b25b-7539e663e926",
186+
"parent_slice": {}
187+
}
188+
},
189+
"cursor": {
190+
"updated_at": "2221-01-01T00:00:00.000Z"
191+
}
192+
},
193+
{
194+
"partition": {
195+
"adaccount_id": "e4cd371b-8de8-4011-a8d2-860fe77c09e1",
196+
"parent_slice": {
197+
"organization_id": "7f064d90-52a1-42db-b25b-7539e663e926",
198+
"parent_slice": {}
199+
}
200+
},
201+
"cursor": {
202+
"updated_at": "2221-01-01T00:00:00.000Z"
203+
}
204+
}
205+
]
65206
}
66207
}
67208
},
68209
{
69210
"type": "STREAM",
70211
"stream": {
71-
"stream_state": {
72-
"updated_at": "2221-01-01T00:00:00Z"
73-
},
74212
"stream_descriptor": {
75-
"name": "segments"
213+
"name": "segments",
214+
"namespace": null
215+
},
216+
"stream_state": {
217+
"states": [
218+
{
219+
"partition": {
220+
"adaccount_id": "04214c00-3aa5-4123-b5c8-363c32c40e42",
221+
"parent_slice": {
222+
"organization_id": "7f064d90-52a1-42db-b25b-7539e663e926",
223+
"parent_slice": {}
224+
}
225+
},
226+
"cursor": {
227+
"updated_at": "2221-01-01T00:00:00.000Z"
228+
}
229+
},
230+
{
231+
"partition": {
232+
"adaccount_id": "e4cd371b-8de8-4011-a8d2-860fe77c09e1",
233+
"parent_slice": {
234+
"organization_id": "7f064d90-52a1-42db-b25b-7539e663e926",
235+
"parent_slice": {}
236+
}
237+
},
238+
"cursor": {
239+
"updated_at": "2221-01-01T00:00:00.000Z"
240+
}
241+
}
242+
]
76243
}
77244
}
78245
}

0 commit comments

Comments
 (0)