Module: Legion::Extensions::Llm::Mlx::Runners::FleetWorker

Extended by:
Logging::Helper
Includes:
Logging::Helper
Defined in:
lib/legion/extensions/llm/mlx/runners/fleet_worker.rb

Overview

Runner entrypoint for MLX fleet request execution. Delegates to the shared ProviderResponder with exact-offering registry support for SSOT v3 execution contracts.

The fleet Subscription actor dispatches this as handle_fleet_request(**message), where message is the decoded request envelope merged with transport metadata, so the signature is kwargs-only. Ack/reject is owned by the Subscription actor, so the responder is called with nil delivery/properties.

Class Method Summary collapse

Class Method Details

.handle_fleet_request(**message) ⇒ Object 



28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
 
# File 'lib/legion/extensions/llm/mlx/runners/fleet_worker.rb', line 28

def handle_fleet_request(**message)
  log.debug do
    "handling MLX fleet request request_id=#{message[:request_id].inspect} " \
      "provider_instance=#{message[:provider_instance].inspect} " \
      "operation=#{message[:operation].inspect}"
  end
  Legion::Extensions::Llm::Fleet::ProviderResponder.call(
    payload: message,
    provider_family: Mlx::PROVIDER_FAMILY,
    provider_class: Mlx::Provider,
    provider_instances: -> { Mlx.discover_instances },
    registry: Legion::Extensions::Llm::Inventory::Registry,
    delivery: nil,
    properties: nil
  )
end