Skip to content

Commit 0c064f1

Browse files
bazarnovbazarnov
authored
🐛 Source Shopify: Improve SubStream state handling (#10915)
1 parent 8f49e19 commit 0c064f1

File tree

9 files changed

+204
-120
lines changed

9 files changed

+204
-120
lines changed

‎airbyte-config/init/src/main/resources/seed/source_definitions.yaml

+1-1
Original file line numberDiff line numberDiff line change
@@ -690,7 +690,7 @@
690690
- name: Shopify
691691
sourceDefinitionId: 9da77001-af33-4bcd-be46-6252bf9342b9
692692
dockerRepository: airbyte/source-shopify
693-
dockerImageTag: 0.1.34
693+
dockerImageTag: 0.1.35
694694
documentationUrl: https://docs.airbyte.io/integrations/sources/shopify
695695
icon: shopify.svg
696696
sourceType: api

‎airbyte-config/init/src/main/resources/seed/source_specs.yaml

+1-1
Original file line numberDiff line numberDiff line change
@@ -7353,7 +7353,7 @@
73537353
supportsNormalization: false
73547354
supportsDBT: false
73557355
supported_destination_sync_modes: []
7356-
- dockerImage: "airbyte/source-shopify:0.1.34"
7356+
- dockerImage: "airbyte/source-shopify:0.1.35"
73577357
spec:
73587358
documentationUrl: "https://docs.airbyte.io/integrations/sources/shopify"
73597359
connectionSpecification:

‎airbyte-integrations/connectors/source-shopify/Dockerfile

+1-1
Original file line numberDiff line numberDiff line change
@@ -28,5 +28,5 @@ COPY source_shopify ./source_shopify
2828
ENV AIRBYTE_ENTRYPOINT "python /airbyte/integration_code/main.py"
2929
ENTRYPOINT ["python", "/airbyte/integration_code/main.py"]
3030

31-
LABEL io.airbyte.version=0.1.34
31+
LABEL io.airbyte.version=0.1.35
3232
LABEL io.airbyte.name=airbyte/source-shopify

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

+43-24
Original file line numberDiff line numberDiff line change
@@ -1,62 +1,81 @@
11
{
22
"customers": {
3-
"updated_at": "2024-07-19T06:41:50-07:00"
3+
"updated_at": "2025-07-08T05:40:38-07:00"
44
},
55
"orders": {
6-
"updated_at": "2024-07-19T06:52:06-07:00"
6+
"updated_at": "2025-07-08T05:40:38-07:00"
77
},
88
"draft_orders": {
9-
"updated_at": "2024-07-07T08:18:59-07:00"
9+
"updated_at": "2025-07-08T05:40:38-07:00"
1010
},
1111
"products": {
12-
"updated_at": "2024-07-19T06:56:06-07:00"
12+
"updated_at": "2025-07-08T05:40:38-07:00"
1313
},
1414
"abandoned_checkouts": {
15-
"updated_at": "2024-07-08T05:41:48-07:00"
15+
"updated_at": "2025-07-08T05:40:38-07:00"
1616
},
1717
"metafields": {
18-
"updated_at": "2024-07-08T03:38:46-07:00"
18+
"updated_at": "2025-07-08T05:40:38-07:00"
1919
},
2020
"collects": {
21-
"id": 99923654213791
21+
"id": 29427031703741
2222
},
2323
"custom_collections": {
24-
"updated_at": "2024-07-19T07:01:37-07:00"
24+
"updated_at": "2025-07-08T05:40:38-07:00"
2525
},
2626
"order_refunds": {
27-
"created_at": "2024-07-19T06:41:47-07:00"
27+
"created_at": "2025-03-03T03:47:46-08:00",
28+
"orders": {
29+
"updated_at": "2025-03-03T03:47:46-08:00"
30+
}
2831
},
2932
"order_risks": {
30-
"id": 9991307599038
33+
"id": 6446736474301,
34+
"orders": {
35+
"updated_at": "2025-02-22T00:37:28-08:00"
36+
}
3137
},
3238
"transactions": {
33-
"created_at": "2024-07-19T06:41:46-07:00"
39+
"created_at": "2025-03-03T03:47:45-08:00",
40+
"orders": {
41+
"updated_at": "2025-03-03T03:47:46-08:00"
42+
}
43+
},
44+
"tender_transactions": {
45+
"processed_at": "2025-03-03T03:47:45-08:00"
3446
},
3547
"pages": {
36-
"updated_at": "2024-07-08T05:24:11-07:00"
48+
"updated_at": "2025-07-08T05:24:10-07:00"
3749
},
3850
"price_rules": {
39-
"updated_at": "2024-07-08T05:57:05-07:00"
51+
"updated_at": "2025-09-10T06:48:10-07:00"
4052
},
4153
"discount_codes": {
42-
"updated_at": "2024-07-08T05:40:38-07:00"
43-
},
44-
"locations": {
45-
"updated_at": "2024-07-08T05:40:38-07:00"
54+
"updated_at": "2025-09-10T06:48:10-07:00",
55+
"price_rules": {
56+
"updated_at": "2025-09-10T06:48:10-07:00"
57+
}
4658
},
4759
"inventory_items": {
48-
"updated_at": "2024-07-08T05:40:38-07:00"
60+
"updated_at": "2025-02-22T00:40:26-08:00",
61+
"products": {
62+
"updated_at": "2025-08-18T02:39:48-07:00"
63+
}
4964
},
5065
"inventory_levels": {
51-
"updated_at": "2024-07-08T05:40:38-07:00"
66+
"updated_at": "2025-03-03T03:47:51-08:00",
67+
"locations": {}
5268
},
5369
"fulfillment_orders": {
54-
"id": 9991307599038
70+
"id": 5424260808893,
71+
"orders": {
72+
"updated_at": "2025-03-03T03:47:46-08:00"
73+
}
5574
},
5675
"fulfillments": {
57-
"updated_at": "2024-07-08T05:40:38-07:00"
58-
},
59-
"tender_transactions": {
60-
"processed_at": "2024-07-08T05:40:38-07:00"
76+
"updated_at": "2025-02-27T23:49:13-08:00",
77+
"orders": {
78+
"updated_at": "2025-03-03T03:47:46-08:00"
79+
}
6180
}
6281
}

‎airbyte-integrations/connectors/source-shopify/integration_tests/state.json

+40-21
Original file line numberDiff line numberDiff line change
@@ -1,18 +1,18 @@
11
{
22
"customers": {
3-
"updated_at": "2021-09-19T09:08:24-07:00"
3+
"updated_at": "2022-03-02T03:23:16-08:00"
44
},
55
"orders": {
6-
"updated_at": "2021-09-19T09:08:24-07:00"
6+
"updated_at": "2022-03-03T03:47:46-08:00"
77
},
88
"draft_orders": {
9-
"updated_at": "2021-07-07T08:18:58-07:00"
9+
"updated_at": "2022-02-22T04:29:57-08:00"
1010
},
1111
"products": {
12-
"updated_at": "2021-09-19T09:10:43-07:00"
12+
"updated_at": "2022-03-03T03:47:51-08:00"
1313
},
1414
"abandoned_checkouts": {
15-
"updated_at": "2021-07-08T05:41:47-07:00"
15+
"updated_at": "2022-03-02T03:23:22-08:00"
1616
},
1717
"metafields": {
1818
"updated_at": "2021-07-08T03:38:45-07:00"
@@ -24,13 +24,25 @@
2424
"updated_at": "2021-08-18T02:39:34-07:00"
2525
},
2626
"order_refunds": {
27-
"created_at": "2021-09-09T02:57:43-07:00"
27+
"created_at": "2022-03-03T03:47:46-08:00",
28+
"orders": {
29+
"updated_at": "2022-03-03T03:47:46-08:00"
30+
}
2831
},
29-
"orders_risks": {
30-
"id": 6161307599036
32+
"order_risks": {
33+
"id": 6446736474301,
34+
"orders": {
35+
"updated_at": "2022-02-22T00:37:28-08:00"
36+
}
3137
},
3238
"transactions": {
33-
"created_at": "2021-09-09T02:57:43-07:00"
39+
"created_at": "2022-03-03T03:47:45-08:00",
40+
"orders": {
41+
"updated_at": "2022-03-03T03:47:46-08:00"
42+
}
43+
},
44+
"tender_transactions": {
45+
"processed_at": "2022-03-03T03:47:45-08:00"
3446
},
3547
"pages": {
3648
"updated_at": "2021-07-08T05:24:10-07:00"
@@ -39,24 +51,31 @@
3951
"updated_at": "2021-09-10T06:48:10-07:00"
4052
},
4153
"discount_codes": {
42-
"updated_at": "2021-09-10T06:48:10-07:00"
43-
},
44-
"locations": {
45-
"updated_at": "2021-09-10T06:48:10-07:00"
54+
"updated_at": "2021-09-10T06:48:10-07:00",
55+
"price_rules": {
56+
"updated_at": "2021-09-10T06:48:10-07:00"
57+
}
4658
},
4759
"inventory_items": {
48-
"updated_at": "2021-09-10T06:48:10-07:00"
60+
"updated_at": "2022-02-22T00:40:26-08:00",
61+
"products": {
62+
"updated_at": "2022-02-18T02:39:48-07:00"
63+
}
4964
},
5065
"inventory_levels": {
51-
"updated_at": "2021-09-10T06:48:10-07:00"
66+
"updated_at": "2022-03-03T03:47:51-08:00",
67+
"locations": {}
5268
},
5369
"fulfillment_orders": {
54-
"id": 123
70+
"id": 5424260808893,
71+
"orders": {
72+
"updated_at": "2022-03-03T03:47:46-08:00"
73+
}
5574
},
5675
"fulfillments": {
57-
"updated_at": "2021-09-10T06:48:10-07:00"
58-
},
59-
"tender_transactions": {
60-
"processed_at": "2021-12-13T20:43:39-08:00"
76+
"updated_at": "2022-02-27T23:49:13-08:00",
77+
"orders": {
78+
"updated_at": "2022-03-03T03:47:46-08:00"
79+
}
6180
}
62-
}
81+
}

0 commit comments

Comments
 (0)