Module: Legion::Extensions::Llm::Anthropic::Runners::FleetWorker

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

Overview

Runner entrypoint for Anthropic fleet request execution.

Invoked by the Subscription actor as runner_class.send(runner_function, **message) — the decoded envelope (symbol keys) merged with delivery metadata. The envelope itself is the responder payload; the actor acks the AMQP delivery after this returns.

Class Method Summary collapse

Class Method Details

.handle_fleet_request(**message) ⇒ Object 



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

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