Module: Legion::Extensions::Llm::Vertex::Runners::FleetWorker

Defined in:
lib/legion/extensions/llm/vertex/runners/fleet_worker.rb

Overview

Runner entrypoint for Vertex fleet request execution.

The Subscription dispatch path invokes this as handle_fleet_request(**message) where message is the decoded protocol-v2 envelope plus AMQP metadata; the whole message is the payload for the shared responder (which selects the envelope fields it needs).

Class Method Summary collapse

Class Method Details

.handle_fleet_request(**message) ⇒ Object 



21
22
23
24
25
26
27
28
 
# File 'lib/legion/extensions/llm/vertex/runners/fleet_worker.rb', line 21

def handle_fleet_request(**message)
  Legion::Extensions::Llm::Fleet::ProviderResponder.call(
    payload: message,
    provider_family: Vertex::PROVIDER_FAMILY,
    provider_class: Vertex::Provider,
    provider_instances: -> { Vertex.discover_instances }
  )
end