diff --git a/clients/algoliasearch-client-javascript/packages/ingestion/src/ingestionClient.ts b/clients/algoliasearch-client-javascript/packages/ingestion/src/ingestionClient.ts index bef6284fa4..bbfdc53579 100644 --- a/clients/algoliasearch-client-javascript/packages/ingestion/src/ingestionClient.ts +++ b/clients/algoliasearch-client-javascript/packages/ingestion/src/ingestionClient.ts @@ -1730,6 +1730,15 @@ export function createIngestionClient({ data: pushTaskPayload, }; + requestOptions = { + timeouts: { + connect: 180000, + read: 180000, + write: 180000, + ...requestOptions?.timeouts, + }, + }; + return transporter.request(request, requestOptions); }, @@ -2075,6 +2084,15 @@ export function createIngestionClient({ headers, }; + requestOptions = { + timeouts: { + connect: 180000, + read: 180000, + write: 180000, + ...requestOptions?.timeouts, + }, + }; + return transporter.request(request, requestOptions); }, @@ -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); }, @@ -2466,6 +2493,15 @@ export function createIngestionClient({ data: sourceUpdate, }; + requestOptions = { + timeouts: { + connect: 180000, + read: 180000, + write: 180000, + ...requestOptions?.timeouts, + }, + }; + return transporter.request(request, requestOptions); }, }; diff --git a/clients/algoliasearch-client-python/algoliasearch/ingestion/client.py b/clients/algoliasearch-client-python/algoliasearch/ingestion/client.py index 1a6facbcd3..94c9259156 100644 --- a/clients/algoliasearch-client-python/algoliasearch/ingestion/client.py +++ b/clients/algoliasearch-client-python/algoliasearch/ingestion/client.py @@ -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, @@ -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, @@ -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, @@ -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, @@ -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, @@ -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, @@ -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, @@ -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, diff --git a/clients/algoliasearch-client-ruby/lib/algolia/api/ingestion_client.rb b/clients/algoliasearch-client-ruby/lib/algolia/api/ingestion_client.rb index 92e4f977af..443a784c85 100644 --- a/clients/algoliasearch-client-ruby/lib/algolia/api/ingestion_client.rb +++ b/clients/algoliasearch-client-ruby/lib/algolia/api/ingestion_client.rb @@ -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) @@ -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] @@ -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) @@ -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) diff --git a/docs/bundled/ingestion.yml b/docs/bundled/ingestion.yml index 91d157d366..f285382912 100644 --- a/docs/bundled/ingestion.yml +++ b/docs/bundled/ingestion.yml @@ -3853,6 +3853,10 @@ paths: - addObject - deleteIndex - editSettings + x-timeouts: + connect: 180000 + read: 180000 + write: 180000 requestBody: description: '' content: @@ -4764,6 +4768,10 @@ paths: - addObject - deleteIndex - editSettings + x-timeouts: + connect: 180000 + read: 180000 + write: 180000 parameters: - $ref: '#/components/parameters/pathSourceID' requestBody: @@ -5025,6 +5033,10 @@ paths: - addObject - deleteIndex - editSettings + x-timeouts: + connect: 180000 + read: 180000 + write: 180000 parameters: - $ref: '#/components/parameters/pathSourceID' responses: @@ -8734,6 +8746,10 @@ paths: - addObject - deleteIndex - editSettings + x-timeouts: + connect: 180000 + read: 180000 + write: 180000 parameters: - $ref: '#/components/parameters/pathTaskID' - name: watch diff --git a/specs/bundled/ingestion.yml b/specs/bundled/ingestion.yml index 745afeef59..14a30961bf 100644 --- a/specs/bundled/ingestion.yml +++ b/specs/bundled/ingestion.yml @@ -639,6 +639,10 @@ paths: - addObject - deleteIndex - editSettings + x-timeouts: + connect: 180000 + read: 180000 + write: 180000 requestBody: description: '' content: @@ -768,6 +772,10 @@ paths: - addObject - deleteIndex - editSettings + x-timeouts: + connect: 180000 + read: 180000 + write: 180000 parameters: - $ref: '#/components/parameters/pathSourceID' requestBody: @@ -800,6 +808,10 @@ paths: - addObject - deleteIndex - editSettings + x-timeouts: + connect: 180000 + read: 180000 + write: 180000 parameters: - $ref: '#/components/parameters/pathSourceID' responses: @@ -1288,6 +1300,10 @@ paths: - addObject - deleteIndex - editSettings + x-timeouts: + connect: 180000 + read: 180000 + write: 180000 parameters: - $ref: '#/components/parameters/pathTaskID' - name: watch