Skip to content

Commit 9002538

Browse files
algolia-botshortcuts
algolia-bot
and
shortcuts
committed
fix(specs): endpoint level timeout for ingestion (#4251) (generated) [skip ci]
Co-authored-by: Clément Vannicatte <[email protected]>
1 parent 679a8cd commit 9002538

File tree

5 files changed

+112
-0
lines changed

5 files changed

+112
-0
lines changed

‎clients/algoliasearch-client-javascript/packages/ingestion/src/ingestionClient.ts

Lines changed: 36 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1730,6 +1730,15 @@ export function createIngestionClient({
17301730
data: pushTaskPayload,
17311731
};
17321732

1733+
requestOptions = {
1734+
timeouts: {
1735+
connect: 180000,
1736+
read: 180000,
1737+
write: 180000,
1738+
...requestOptions?.timeouts,
1739+
},
1740+
};
1741+
17331742
return transporter.request(request, requestOptions);
17341743
},
17351744

@@ -2075,6 +2084,15 @@ export function createIngestionClient({
20752084
headers,
20762085
};
20772086

2087+
requestOptions = {
2088+
timeouts: {
2089+
connect: 180000,
2090+
read: 180000,
2091+
write: 180000,
2092+
...requestOptions?.timeouts,
2093+
},
2094+
};
2095+
20782096
return transporter.request(request, requestOptions);
20792097
},
20802098

@@ -2427,6 +2445,15 @@ export function createIngestionClient({
24272445
data: sourceCreate ? sourceCreate : {},
24282446
};
24292447

2448+
requestOptions = {
2449+
timeouts: {
2450+
connect: 180000,
2451+
read: 180000,
2452+
write: 180000,
2453+
...requestOptions?.timeouts,
2454+
},
2455+
};
2456+
24302457
return transporter.request(request, requestOptions);
24312458
},
24322459

@@ -2466,6 +2493,15 @@ export function createIngestionClient({
24662493
data: sourceUpdate,
24672494
};
24682495

2496+
requestOptions = {
2497+
timeouts: {
2498+
connect: 180000,
2499+
read: 180000,
2500+
write: 180000,
2501+
...requestOptions?.timeouts,
2502+
},
2503+
};
2504+
24692505
return transporter.request(request, requestOptions);
24702506
},
24712507
};

‎clients/algoliasearch-client-python/algoliasearch/ingestion/client.py

Lines changed: 40 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3512,6 +3512,11 @@ async def push_task_with_http_info(
35123512
request_options=self._request_options.merge(
35133513
query_parameters=_query_parameters,
35143514
data=dumps(body_serializer(_data)),
3515+
timeouts={
3516+
"read": 180000,
3517+
"write": 180000,
3518+
"connect": 180000,
3519+
},
35153520
user_request_options=request_options,
35163521
),
35173522
use_read_transporter=False,
@@ -4144,6 +4149,11 @@ async def trigger_docker_source_discover_with_http_info(
41444149
"{sourceID}", quote(str(source_id), safe="")
41454150
),
41464151
request_options=self._request_options.merge(
4152+
timeouts={
4153+
"read": 180000,
4154+
"write": 180000,
4155+
"connect": 180000,
4156+
},
41474157
user_request_options=request_options,
41484158
),
41494159
use_read_transporter=False,
@@ -4783,6 +4793,11 @@ async def validate_source_with_http_info(
47834793
path="/1/sources/validate",
47844794
request_options=self._request_options.merge(
47854795
data=dumps(body_serializer(_data)),
4796+
timeouts={
4797+
"read": 180000,
4798+
"write": 180000,
4799+
"connect": 180000,
4800+
},
47864801
user_request_options=request_options,
47874802
),
47884803
use_read_transporter=False,
@@ -4854,6 +4869,11 @@ async def validate_source_before_update_with_http_info(
48544869
),
48554870
request_options=self._request_options.merge(
48564871
data=dumps(body_serializer(_data)),
4872+
timeouts={
4873+
"read": 180000,
4874+
"write": 180000,
4875+
"connect": 180000,
4876+
},
48574877
user_request_options=request_options,
48584878
),
48594879
use_read_transporter=False,
@@ -8267,6 +8287,11 @@ def push_task_with_http_info(
82678287
request_options=self._request_options.merge(
82688288
query_parameters=_query_parameters,
82698289
data=dumps(body_serializer(_data)),
8290+
timeouts={
8291+
"read": 180000,
8292+
"write": 180000,
8293+
"connect": 180000,
8294+
},
82708295
user_request_options=request_options,
82718296
),
82728297
use_read_transporter=False,
@@ -8899,6 +8924,11 @@ def trigger_docker_source_discover_with_http_info(
88998924
"{sourceID}", quote(str(source_id), safe="")
89008925
),
89018926
request_options=self._request_options.merge(
8927+
timeouts={
8928+
"read": 180000,
8929+
"write": 180000,
8930+
"connect": 180000,
8931+
},
89028932
user_request_options=request_options,
89038933
),
89048934
use_read_transporter=False,
@@ -9534,6 +9564,11 @@ def validate_source_with_http_info(
95349564
path="/1/sources/validate",
95359565
request_options=self._request_options.merge(
95369566
data=dumps(body_serializer(_data)),
9567+
timeouts={
9568+
"read": 180000,
9569+
"write": 180000,
9570+
"connect": 180000,
9571+
},
95379572
user_request_options=request_options,
95389573
),
95399574
use_read_transporter=False,
@@ -9605,6 +9640,11 @@ def validate_source_before_update_with_http_info(
96059640
),
96069641
request_options=self._request_options.merge(
96079642
data=dumps(body_serializer(_data)),
9643+
timeouts={
9644+
"read": 180000,
9645+
"write": 180000,
9646+
"connect": 180000,
9647+
},
96089648
user_request_options=request_options,
96099649
),
96109650
use_read_transporter=False,

‎clients/algoliasearch-client-ruby/lib/algolia/api/ingestion_client.rb

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2151,6 +2151,7 @@ def push_task_with_http_info(task_id, push_task_payload, watch = nil, request_op
21512151
query_params = query_params.merge(request_options[:query_params]) unless request_options[:query_params].nil?
21522152
header_params = {}
21532153
header_params = header_params.merge(request_options[:header_params]) unless request_options[:header_params].nil?
2154+
request_options[:timeout] ||= 180000
21542155

21552156
post_body = request_options[:debug_body] || @api_client.object_to_http_body(push_task_payload)
21562157

@@ -2635,6 +2636,7 @@ def trigger_docker_source_discover_with_http_info(source_id, request_options = {
26352636
query_params = query_params.merge(request_options[:query_params]) unless request_options[:query_params].nil?
26362637
header_params = {}
26372638
header_params = header_params.merge(request_options[:header_params]) unless request_options[:header_params].nil?
2639+
request_options[:timeout] ||= 180000
26382640

26392641
post_body = request_options[:debug_body]
26402642

@@ -3113,6 +3115,7 @@ def validate_source_with_http_info(source_create = nil, request_options = {})
31133115
query_params = query_params.merge(request_options[:query_params]) unless request_options[:query_params].nil?
31143116
header_params = {}
31153117
header_params = header_params.merge(request_options[:header_params]) unless request_options[:header_params].nil?
3118+
request_options[:timeout] ||= 180000
31163119

31173120
post_body = request_options[:debug_body] || @api_client.object_to_http_body(source_create)
31183121

@@ -3166,6 +3169,7 @@ def validate_source_before_update_with_http_info(source_id, source_update, reque
31663169
query_params = query_params.merge(request_options[:query_params]) unless request_options[:query_params].nil?
31673170
header_params = {}
31683171
header_params = header_params.merge(request_options[:header_params]) unless request_options[:header_params].nil?
3172+
request_options[:timeout] ||= 180000
31693173

31703174
post_body = request_options[:debug_body] || @api_client.object_to_http_body(source_update)
31713175

‎docs/bundled/ingestion.yml

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3853,6 +3853,10 @@ paths:
38533853
- addObject
38543854
- deleteIndex
38553855
- editSettings
3856+
x-timeouts:
3857+
connect: 180000
3858+
read: 180000
3859+
write: 180000
38563860
requestBody:
38573861
description: ''
38583862
content:
@@ -4764,6 +4768,10 @@ paths:
47644768
- addObject
47654769
- deleteIndex
47664770
- editSettings
4771+
x-timeouts:
4772+
connect: 180000
4773+
read: 180000
4774+
write: 180000
47674775
parameters:
47684776
- $ref: '#/components/parameters/pathSourceID'
47694777
requestBody:
@@ -5025,6 +5033,10 @@ paths:
50255033
- addObject
50265034
- deleteIndex
50275035
- editSettings
5036+
x-timeouts:
5037+
connect: 180000
5038+
read: 180000
5039+
write: 180000
50285040
parameters:
50295041
- $ref: '#/components/parameters/pathSourceID'
50305042
responses:
@@ -8734,6 +8746,10 @@ paths:
87348746
- addObject
87358747
- deleteIndex
87368748
- editSettings
8749+
x-timeouts:
8750+
connect: 180000
8751+
read: 180000
8752+
write: 180000
87378753
parameters:
87388754
- $ref: '#/components/parameters/pathTaskID'
87398755
- name: watch

‎specs/bundled/ingestion.yml

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -639,6 +639,10 @@ paths:
639639
- addObject
640640
- deleteIndex
641641
- editSettings
642+
x-timeouts:
643+
connect: 180000
644+
read: 180000
645+
write: 180000
642646
requestBody:
643647
description: ''
644648
content:
@@ -768,6 +772,10 @@ paths:
768772
- addObject
769773
- deleteIndex
770774
- editSettings
775+
x-timeouts:
776+
connect: 180000
777+
read: 180000
778+
write: 180000
771779
parameters:
772780
- $ref: '#/components/parameters/pathSourceID'
773781
requestBody:
@@ -800,6 +808,10 @@ paths:
800808
- addObject
801809
- deleteIndex
802810
- editSettings
811+
x-timeouts:
812+
connect: 180000
813+
read: 180000
814+
write: 180000
803815
parameters:
804816
- $ref: '#/components/parameters/pathSourceID'
805817
responses:
@@ -1288,6 +1300,10 @@ paths:
12881300
- addObject
12891301
- deleteIndex
12901302
- editSettings
1303+
x-timeouts:
1304+
connect: 180000
1305+
read: 180000
1306+
write: 180000
12911307
parameters:
12921308
- $ref: '#/components/parameters/pathTaskID'
12931309
- name: watch

0 commit comments

Comments
 (0)