Class: Qs::QsRunner

Inherits:
Runner show all
Defined in:
lib/qs/qs_runner.rb

Defined Under Namespace

Modules: OptionalTimeout

Instance Attribute Summary collapse

Attributes inherited from Runner

#handler, #handler_class, #logger, #message, #params

Instance Method Summary collapse

Constructor Details

#initialize(handler_class, args = nil) ⇒ QsRunner 



11
12
13
14
 
# File 'lib/qs/qs_runner.rb', line 11

def initialize(handler_class, args = nil)
  super(handler_class, args)
  @timeout = handler_class.timeout || Qs.config.timeout
end

Instance Attribute Details

#timeout ⇒ Object (readonly)

Returns the value of attribute timeout.



9
10
11
 
# File 'lib/qs/qs_runner.rb', line 9

def timeout
  @timeout
end

Instance Method Details

#run ⇒ Object 



16
17
18
19
20
21
22
23
24
25
26
27
 
# File 'lib/qs/qs_runner.rb', line 16

def run
  OptionalTimeout.new(self.timeout) do
    run_callbacks self.handler_class.before_callbacks
    self.handler.init
    self.handler.run
    run_callbacks self.handler_class.after_callbacks
  end
rescue TimeoutError => exception
  error = TimeoutError.new "#{handler_class} timed out (#{timeout}s)"
  error.set_backtrace(exception.backtrace)
  raise error
end