Class: Openlayer::Resources::InferencePipelines::Data

Inherits:

Object

• Object
• Openlayer::Resources::InferencePipelines::Data

Defined in:

lib/openlayer/resources/inference_pipelines/data.rb

Instance Method Summary

• #initialize(client:) ⇒ Data constructor private

  A new instance of Data.

• #stream(inference_pipeline_id, config: , rows: , request_options: {}) ⇒ Openlayer::Models::InferencePipelines::DataStreamResponse

  Some parameter documentations has been truncated, see Models::InferencePipelines::DataStreamParams for more details.

Constructor Details

#initialize(client:) ⇒ Data

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 Data.

Parameters:

• client (Openlayer::Client)

# File 'lib/openlayer/resources/inference_pipelines/data.rb', line 40

def initialize(client:)
  @client = client
end

Instance Method Details

#stream(inference_pipeline_id, config: , rows: , request_options: {}) ⇒ Openlayer::Models::InferencePipelines::DataStreamResponse

Some parameter documentations has been truncated, see Models::InferencePipelines::DataStreamParams for more details.

Publish an inference data point to an inference pipeline.

type

Parameters:

• inference_pipeline_id (String) —

  The inference pipeline id (a UUID).

• config (Openlayer::Models::InferencePipelines::DataStreamParams::Config::LlmData, Openlayer::Models::InferencePipelines::DataStreamParams::Config::TabularClassificationData, Openlayer::Models::InferencePipelines::DataStreamParams::Config::TabularRegressionData, Openlayer::Models::InferencePipelines::DataStreamParams::Config::TextClassificationData) —

  Configuration for the data stream. Depends on your **Openlayer project task

• rows (Array<Hash{Symbol=>Object}>) —

  A list of inference data points with inputs and outputs

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

Returns:

• (Openlayer::Models::InferencePipelines::DataStreamResponse)

See Also:

• Models::InferencePipelines::DataStreamParams

# File 'lib/openlayer/resources/inference_pipelines/data.rb', line 26

def stream(inference_pipeline_id, params)
  parsed, options = Openlayer::InferencePipelines::DataStreamParams.dump_request(params)
  @client.request(
    method: :post,
    path: ["inference-pipelines/%1$s/data-stream", inference_pipeline_id],
    body: parsed,
    model: Openlayer::Models::InferencePipelines::DataStreamResponse,
    options: options
  )
end