Skip to content

Commit

Permalink
fix(specs): enable watcher for push [skip-bc] (generated)
Browse files Browse the repository at this point in the history
algolia/api-clients-automation#4229

Co-authored-by: algolia-bot <accounts+algolia-api-client-bot@algolia.com>
Co-authored-by: Clément Vannicatte <vannicattec@gmail.com>
  • Loading branch information
algolia-bot and shortcuts committed Dec 11, 2024
1 parent 19cf039 commit 3334832
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 12 deletions.
16 changes: 8 additions & 8 deletions lib/algolia/api/ingestion_client.rb
Original file line number Diff line number Diff line change
Expand Up @@ -2175,10 +2175,10 @@ def push_task_with_http_info(task_id, push_task_payload, watch = nil, request_op
# @param push_task_payload [PushTaskPayload] Request body of a Search API `batch` request that will be pushed in the Connectors pipeline. (required)
# @param watch [Boolean] When provided, the push operation will be synchronous and the API will wait for the ingestion to be finished before responding.
# @param request_options: The request options to send along with the query, they will be merged with the transporter base parameters (headers, query params, timeouts, etc.). (optional)
# @return [RunResponse]
# @return [WatchResponse]
def push_task(task_id, push_task_payload, watch = nil, request_options = {})
response = push_task_with_http_info(task_id, push_task_payload, watch, request_options)
@api_client.deserialize(response.body, request_options[:debug_return_type] || "Ingestion::RunResponse")
@api_client.deserialize(response.body, request_options[:debug_return_type] || "Ingestion::WatchResponse")
end

# Runs all tasks linked to a source, only available for Shopify sources. It will create 1 run per task.
Expand Down Expand Up @@ -2657,10 +2657,10 @@ def trigger_docker_source_discover_with_http_info(source_id, request_options = {
# - editSettings
# @param source_id [String] Unique identifier of a source. (required)
# @param request_options: The request options to send along with the query, they will be merged with the transporter base parameters (headers, query params, timeouts, etc.). (optional)
# @return [SourceWatchResponse]
# @return [WatchResponse]
def trigger_docker_source_discover(source_id, request_options = {})
response = trigger_docker_source_discover_with_http_info(source_id, request_options)
@api_client.deserialize(response.body, request_options[:debug_return_type] || "Ingestion::SourceWatchResponse")
@api_client.deserialize(response.body, request_options[:debug_return_type] || "Ingestion::WatchResponse")
end

# Try a transformation before creating it.
Expand Down Expand Up @@ -3135,10 +3135,10 @@ def validate_source_with_http_info(source_create = nil, request_options = {})
# - editSettings
# @param source_create [SourceCreate]
# @param request_options: The request options to send along with the query, they will be merged with the transporter base parameters (headers, query params, timeouts, etc.). (optional)
# @return [SourceWatchResponse]
# @return [WatchResponse]
def validate_source(source_create = nil, request_options = {})
response = validate_source_with_http_info(source_create, request_options)
@api_client.deserialize(response.body, request_options[:debug_return_type] || "Ingestion::SourceWatchResponse")
@api_client.deserialize(response.body, request_options[:debug_return_type] || "Ingestion::WatchResponse")
end

# Validates an update of a source payload to ensure it can be created and that the data source can be reached by Algolia.
Expand Down Expand Up @@ -3189,10 +3189,10 @@ def validate_source_before_update_with_http_info(source_id, source_update, reque
# @param source_id [String] Unique identifier of a source. (required)
# @param source_update [SourceUpdate] (required)
# @param request_options: The request options to send along with the query, they will be merged with the transporter base parameters (headers, query params, timeouts, etc.). (optional)
# @return [SourceWatchResponse]
# @return [WatchResponse]
def validate_source_before_update(source_id, source_update, request_options = {})
response = validate_source_before_update_with_http_info(source_id, source_update, request_options)
@api_client.deserialize(response.body, request_options[:debug_return_type] || "Ingestion::SourceWatchResponse")
@api_client.deserialize(response.body, request_options[:debug_return_type] || "Ingestion::WatchResponse")
end

end
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,11 +5,11 @@

module Algolia
module Ingestion
class SourceWatchResponse
class WatchResponse
# Universally unique identifier (UUID) of a task run.
attr_accessor :run_id

# depending on the source type, the validation returns sampling data of your source (JSON, CSV, BigQuery).
# when used with discovering or validating sources, the sampled data of your source is returned.
attr_accessor :data

# in case of error, observability events will be added to the response, if any.
Expand Down Expand Up @@ -56,7 +56,7 @@ def initialize(attributes = {})
if (!attributes.is_a?(Hash))
raise(
ArgumentError,
"The input argument (attributes) must be a hash in `Algolia::SourceWatchResponse` initialize method"
"The input argument (attributes) must be a hash in `Algolia::WatchResponse` initialize method"
)
end

Expand All @@ -65,7 +65,7 @@ def initialize(attributes = {})
if (!self.class.attribute_map.key?(k.to_sym))
raise(
ArgumentError,
"`#{k}` is not a valid attribute in `Algolia::SourceWatchResponse`. Please check the name to make sure it's valid. List of attributes: " +
"`#{k}` is not a valid attribute in `Algolia::WatchResponse`. Please check the name to make sure it's valid. List of attributes: " +
self.class.attribute_map.keys.inspect
)
end
Expand Down

0 comments on commit 3334832

Please sign in to comment.