Skip to content

Commit

Permalink
fix(specs): endpoint level timeout for ingestion (#4251) (generated) …
Browse files Browse the repository at this point in the history 
…[skip ci]

Co-authored-by: Clément Vannicatte <vannicattec@gmail.com>
  • Loading branch information
@algolia-bot @shortcuts
algolia-bot and shortcuts committed Dec 18, 2024
1 parent 679a8cd commit 9002538
Show file tree
Hide file tree
Showing 5 changed files with 112 additions and 0 deletions.
36 changes: 36 additions & 0 deletions clients/algoliasearch-client-javascript/packages/ingestion/src/ingestionClient.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1730,6 +1730,15 @@ export function createIngestionClient({
data: pushTaskPayload,
};

requestOptions = {
timeouts: {
connect: 180000,
read: 180000,
write: 180000,
...requestOptions?.timeouts,
},
};

return transporter.request(request, requestOptions);
},

Expand Down Expand Up @@ -2075,6 +2084,15 @@ export function createIngestionClient({
headers,
};

requestOptions = {
timeouts: {
connect: 180000,
read: 180000,
write: 180000,
...requestOptions?.timeouts,
},
};

return transporter.request(request, requestOptions);
},

Expand Down Expand Up @@ -2427,6 +2445,15 @@ export function createIngestionClient({
data: sourceCreate ? sourceCreate : {},
};

requestOptions = {
timeouts: {
connect: 180000,
read: 180000,
write: 180000,
...requestOptions?.timeouts,
},
};

return transporter.request(request, requestOptions);
},

Expand Down Expand Up @@ -2466,6 +2493,15 @@ export function createIngestionClient({
data: sourceUpdate,
};

requestOptions = {
timeouts: {
connect: 180000,
read: 180000,
write: 180000,
...requestOptions?.timeouts,
},
};

return transporter.request(request, requestOptions);
},
};
Expand Down
40 changes: 40 additions & 0 deletions clients/algoliasearch-client-python/algoliasearch/ingestion/client.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -3512,6 +3512,11 @@ async def push_task_with_http_info(
request_options=self._request_options.merge(
query_parameters=_query_parameters,
data=dumps(body_serializer(_data)),
timeouts={
"read": 180000,
"write": 180000,
"connect": 180000,
},
user_request_options=request_options,
),
use_read_transporter=False,
Expand Down Expand Up @@ -4144,6 +4149,11 @@ async def trigger_docker_source_discover_with_http_info(
"{sourceID}", quote(str(source_id), safe="")
),
request_options=self._request_options.merge(
timeouts={
"read": 180000,
"write": 180000,
"connect": 180000,
},
user_request_options=request_options,
),
use_read_transporter=False,
Expand Down Expand Up @@ -4783,6 +4793,11 @@ async def validate_source_with_http_info(
path="/1/sources/validate",
request_options=self._request_options.merge(
data=dumps(body_serializer(_data)),
timeouts={
"read": 180000,
"write": 180000,
"connect": 180000,
},
user_request_options=request_options,
),
use_read_transporter=False,
Expand Down Expand Up @@ -4854,6 +4869,11 @@ async def validate_source_before_update_with_http_info(
),
request_options=self._request_options.merge(
data=dumps(body_serializer(_data)),
timeouts={
"read": 180000,
"write": 180000,
"connect": 180000,
},
user_request_options=request_options,
),
use_read_transporter=False,
Expand Down Expand Up @@ -8267,6 +8287,11 @@ def push_task_with_http_info(
request_options=self._request_options.merge(
query_parameters=_query_parameters,
data=dumps(body_serializer(_data)),
timeouts={
"read": 180000,
"write": 180000,
"connect": 180000,
},
user_request_options=request_options,
),
use_read_transporter=False,
Expand Down Expand Up @@ -8899,6 +8924,11 @@ def trigger_docker_source_discover_with_http_info(
"{sourceID}", quote(str(source_id), safe="")
),
request_options=self._request_options.merge(
timeouts={
"read": 180000,
"write": 180000,
"connect": 180000,
},
user_request_options=request_options,
),
use_read_transporter=False,
Expand Down Expand Up @@ -9534,6 +9564,11 @@ def validate_source_with_http_info(
path="/1/sources/validate",
request_options=self._request_options.merge(
data=dumps(body_serializer(_data)),
timeouts={
"read": 180000,
"write": 180000,
"connect": 180000,
},
user_request_options=request_options,
),
use_read_transporter=False,
Expand Down Expand Up @@ -9605,6 +9640,11 @@ def validate_source_before_update_with_http_info(
),
request_options=self._request_options.merge(
data=dumps(body_serializer(_data)),
timeouts={
"read": 180000,
"write": 180000,
"connect": 180000,
},
user_request_options=request_options,
),
use_read_transporter=False,
Expand Down
4 changes: 4 additions & 0 deletions clients/algoliasearch-client-ruby/lib/algolia/api/ingestion_client.rb
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2151,6 +2151,7 @@ def push_task_with_http_info(task_id, push_task_payload, watch = nil, request_op
query_params = query_params.merge(request_options[:query_params]) unless request_options[:query_params].nil?
header_params = {}
header_params = header_params.merge(request_options[:header_params]) unless request_options[:header_params].nil?
request_options[:timeout] ||= 180000

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

Expand Down Expand Up @@ -2635,6 +2636,7 @@ def trigger_docker_source_discover_with_http_info(source_id, request_options = {
query_params = query_params.merge(request_options[:query_params]) unless request_options[:query_params].nil?
header_params = {}
header_params = header_params.merge(request_options[:header_params]) unless request_options[:header_params].nil?
request_options[:timeout] ||= 180000

post_body = request_options[:debug_body]

Expand Down Expand Up @@ -3113,6 +3115,7 @@ def validate_source_with_http_info(source_create = nil, request_options = {})
query_params = query_params.merge(request_options[:query_params]) unless request_options[:query_params].nil?
header_params = {}
header_params = header_params.merge(request_options[:header_params]) unless request_options[:header_params].nil?
request_options[:timeout] ||= 180000

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

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

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

Expand Down
16 changes: 16 additions & 0 deletions docs/bundled/ingestion.yml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -3853,6 +3853,10 @@ paths:
- addObject
- deleteIndex
- editSettings
x-timeouts:
connect: 180000
read: 180000
write: 180000
requestBody:
description: ''
content:
Expand Down Expand Up @@ -4764,6 +4768,10 @@ paths:
- addObject
- deleteIndex
- editSettings
x-timeouts:
connect: 180000
read: 180000
write: 180000
parameters:
- $ref: '#/components/parameters/pathSourceID'
requestBody:
Expand Down Expand Up @@ -5025,6 +5033,10 @@ paths:
- addObject
- deleteIndex
- editSettings
x-timeouts:
connect: 180000
read: 180000
write: 180000
parameters:
- $ref: '#/components/parameters/pathSourceID'
responses:
Expand Down Expand Up @@ -8734,6 +8746,10 @@ paths:
- addObject
- deleteIndex
- editSettings
x-timeouts:
connect: 180000
read: 180000
write: 180000
parameters:
- $ref: '#/components/parameters/pathTaskID'
- name: watch
Expand Down
16 changes: 16 additions & 0 deletions specs/bundled/ingestion.yml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -639,6 +639,10 @@ paths:
- addObject
- deleteIndex
- editSettings
x-timeouts:
connect: 180000
read: 180000
write: 180000
requestBody:
description: ''
content:
Expand Down Expand Up @@ -768,6 +772,10 @@ paths:
- addObject
- deleteIndex
- editSettings
x-timeouts:
connect: 180000
read: 180000
write: 180000
parameters:
- $ref: '#/components/parameters/pathSourceID'
requestBody:
Expand Down Expand Up @@ -800,6 +808,10 @@ paths:
- addObject
- deleteIndex
- editSettings
x-timeouts:
connect: 180000
read: 180000
write: 180000
parameters:
- $ref: '#/components/parameters/pathSourceID'
responses:
Expand Down Expand Up @@ -1288,6 +1300,10 @@ paths:
- addObject
- deleteIndex
- editSettings
x-timeouts:
connect: 180000
read: 180000
write: 180000
parameters:
- $ref: '#/components/parameters/pathTaskID'
- name: watch
Expand Down

0 comments on commit 9002538

Please sign in to comment.