Class: Openlayer::Resources::InferencePipelines::Rows

Inherits:
Object
  • Object
show all
Defined in:
lib/openlayer/resources/inference_pipelines/rows.rb

Instance Method Summary collapse

Constructor Details

#initialize(client:) ⇒ Rows

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Returns a new instance of Rows.

Parameters:



143
144
145
# File 'lib/openlayer/resources/inference_pipelines/rows.rb', line 143

def initialize(client:)
  @client = client
end

Instance Method Details

#delete(inference_id, inference_pipeline_id:, request_options: {}) ⇒ nil

Delete a single inference pipeline row by inference ID. Only project admins can perform this action.

Parameters:

  • inference_id (String)
  • inference_pipeline_id (String)

    The inference pipeline id (a UUID).

  • request_options (Openlayer::RequestOptions, Hash{Symbol=>Object}, nil)

Returns:

  • (nil)

See Also:



126
127
128
129
130
131
132
133
134
135
136
137
138
# File 'lib/openlayer/resources/inference_pipelines/rows.rb', line 126

def delete(inference_id, params)
  parsed, options = Openlayer::InferencePipelines::RowDeleteParams.dump_request(params)
  inference_pipeline_id =
    parsed.delete(:inference_pipeline_id) do
      raise ArgumentError.new("missing required path argument #{_1}")
    end
  @client.request(
    method: :delete,
    path: ["inference-pipelines/%1$s/rows/%2$s", inference_pipeline_id, inference_id],
    model: NilClass,
    options: options
  )
end

#list(inference_pipeline_id, asc: nil, page: nil, per_page: nil, sort_column: nil, column_filters: nil, exclude_row_id_list: nil, not_search_query_and: nil, not_search_query_or: nil, row_id_list: nil, search_query_and: nil, search_query_or: nil, request_options: {}) ⇒ Openlayer::Models::InferencePipelines::RowListResponse

A list of rows for an inference pipeline.

Parameters:

Returns:

See Also:



98
99
100
101
102
103
104
105
106
107
108
109
110
# File 'lib/openlayer/resources/inference_pipelines/rows.rb', line 98

def list(inference_pipeline_id, params = {})
  query_params = [:asc, :page, :per_page, :sort_column]
  parsed, options = Openlayer::InferencePipelines::RowListParams.dump_request(params)
  query = Openlayer::Internal::Util.encode_query_params(parsed.slice(*query_params))
  @client.request(
    method: :post,
    path: ["inference-pipelines/%1$s/rows", inference_pipeline_id],
    query: query.transform_keys(per_page: "perPage", sort_column: "sortColumn"),
    body: parsed.except(*query_params),
    model: Openlayer::Models::InferencePipelines::RowListResponse,
    options: options
  )
end

#retrieve(inference_id, inference_pipeline_id:, request_options: {}) ⇒ Openlayer::Models::InferencePipelines::RowRetrieveResponse

Fetch a single inference pipeline row by inference ID, including OTel steps.

Parameters:

  • inference_id (String)
  • inference_pipeline_id (String)

    The inference pipeline id (a UUID).

  • request_options (Openlayer::RequestOptions, Hash{Symbol=>Object}, nil)

Returns:

See Also:



20
21
22
23
24
25
26
27
28
29
30
31
32
# File 'lib/openlayer/resources/inference_pipelines/rows.rb', line 20

def retrieve(inference_id, params)
  parsed, options = Openlayer::InferencePipelines::RowRetrieveParams.dump_request(params)
  inference_pipeline_id =
    parsed.delete(:inference_pipeline_id) do
      raise ArgumentError.new("missing required path argument #{_1}")
    end
  @client.request(
    method: :get,
    path: ["inference-pipelines/%1$s/rows/%2$s", inference_pipeline_id, inference_id],
    model: Openlayer::Models::InferencePipelines::RowRetrieveResponse,
    options: options
  )
end

#update(inference_pipeline_id, inference_id:, row:, config: nil, request_options: {}) ⇒ Openlayer::Models::InferencePipelines::RowUpdateResponse

Update an inference data point in an inference pipeline.

Parameters:

Returns:

See Also:



51
52
53
54
55
56
57
58
59
60
61
62
63
# File 'lib/openlayer/resources/inference_pipelines/rows.rb', line 51

def update(inference_pipeline_id, params)
  query_params = [:inference_id]
  parsed, options = Openlayer::InferencePipelines::RowUpdateParams.dump_request(params)
  query = Openlayer::Internal::Util.encode_query_params(parsed.slice(*query_params))
  @client.request(
    method: :put,
    path: ["inference-pipelines/%1$s/rows", inference_pipeline_id],
    query: query.transform_keys(inference_id: "inferenceId"),
    body: parsed.except(*query_params),
    model: Openlayer::Models::InferencePipelines::RowUpdateResponse,
    options: options
  )
end