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 



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

def handle_fleet_request(**opts)
  # L6: the responder's dead provider_class/provider_instances
  # params are gone from the 0.8.0 core — v3 dispatch is
  # exact-only and never constructs a provider here.
  Legion::Extensions::Llm::Fleet::ProviderResponder.call(
    payload: opts,
    provider_family: AzureFoundry::PROVIDER_FAMILY,
    delivery: opts[:delivery],
    properties: opts[:properties]
  )
end