Class: Legion::Extensions::Apollo::Actor::GasSubscriber

Inherits:
Legion::Extensions::Actors::Subscription
  • Object
show all
Defined in:
lib/legion/extensions/apollo/actors/gas_subscriber.rb

Instance Method Summary collapse

Instance Method Details

#check_subtask? ⇒ Boolean

Returns:

  • (Boolean) 


12
 
# File 'lib/legion/extensions/apollo/actors/gas_subscriber.rb', line 12

def check_subtask?  = false

#create_queue ⇒ Object 



24
25
26
27
28
29
30
31
 
# File 'lib/legion/extensions/apollo/actors/gas_subscriber.rb', line 24

def create_queue
  return if queues.const_defined?(:GasSubscriber, false)

  queues.const_set(:GasSubscriber, Apollo::Transport::Queues::GasSubscriber) unless queues.const_defined?(:GasSubscriber, false)
  exchange_object = Apollo::Transport::Exchanges::LlmAudit.new
  queue_object = Apollo::Transport::Queues::GasSubscriber.new
  queue_object.bind(exchange_object, routing_key: 'llm.audit.complete')
end

#enabled? ⇒ Boolean

rubocop:disable Legion/Extension/ActorEnabledSideEffects

Returns:

  • (Boolean) 


16
17
18
19
20
21
22
 
# File 'lib/legion/extensions/apollo/actors/gas_subscriber.rb', line 16

def enabled? # rubocop:disable Legion/Extension/ActorEnabledSideEffects
  defined?(Legion::Extensions::Apollo::Runners::Gas) &&
    Legion.const_defined?(:Transport, false)
rescue StandardError => e
  log.warn("GasSubscriber enabled? check failed: #{e.message}")
  false
end

#generate_task? ⇒ Boolean

Returns:

  • (Boolean) 


13
 
# File 'lib/legion/extensions/apollo/actors/gas_subscriber.rb', line 13

def generate_task?  = false

#runner_class ⇒ Object 



10
 
# File 'lib/legion/extensions/apollo/actors/gas_subscriber.rb', line 10

def runner_class    = 'Legion::Extensions::Apollo::Runners::Gas'

#runner_function ⇒ Object 



11
 
# File 'lib/legion/extensions/apollo/actors/gas_subscriber.rb', line 11

def runner_function = 'process'

#use_runner? ⇒ Boolean

Returns:

  • (Boolean) 


14
 
# File 'lib/legion/extensions/apollo/actors/gas_subscriber.rb', line 14

def use_runner?     = false