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
 
# 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,
    registry:        Legion::Extensions::Llm::Inventory::Registry
  )
end