Module: Legion::Extensions::Llm::AzureFoundry::Runners::FleetWorker

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

Overview

Runner entrypoint for Azure Foundry fleet request execution.

The Subscription dispatch path invokes this as runner_class.send(fn, **message) where message is the fleet request envelope merged with transport metadata (routing_key, message_id, headers, ...). The responder parses the envelope out of that hash; unknown keys are inert. Errors propagate to the Subscription's rescue (logged + retry-or-DLQ) — never swallowed.

Class Method Summary collapse

Class Method Details

.handle_fleet_request(**opts) ⇒ Object 



23
24
25
26
27
28
29
30
31
32
33
 
# File 'lib/legion/extensions/llm/azure_foundry/runners/fleet_worker.rb', line 23

def handle_fleet_request(**opts)
  Legion::Extensions::Llm::Fleet::ProviderResponder.call(
    payload: opts,
    provider_family: AzureFoundry::PROVIDER_FAMILY,
    provider_class: AzureFoundry::Provider,
    provider_instances: -> { AzureFoundry.discover_instances },
    registry: Legion::Extensions::Llm::Inventory::Registry,
    delivery: opts[:delivery],
    properties: opts[:properties]
  )
end