Class: ForemanTasksCore::Runner::Base

Inherits:
Object
  • Object
show all
Defined in:
lib/foreman_tasks_core/runner/base.rb

Overview

Runner is an object that is able to initiate some action and provide update data on refresh call.

Direct Known Subclasses

CommandRunner

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(*_args) ⇒ Base

Returns a new instance of Base.



9
10
11
12
 
# File 'lib/foreman_tasks_core/runner/base.rb', line 9

def initialize(*_args)
  @id = SecureRandom.uuid
  @continuous_output = ::ForemanTasksCore::ContinuousOutput.new
end

Instance Attribute Details

#id ⇒ Object (readonly)

Returns the value of attribute id.



6
7
8
 
# File 'lib/foreman_tasks_core/runner/base.rb', line 6

def id
  @id
end

#logger ⇒ Object

Returns the value of attribute logger.



7
8
9
 
# File 'lib/foreman_tasks_core/runner/base.rb', line 7

def logger
  @logger
end

Instance Method Details

#close ⇒ Object 



40
41
42
 
# File 'lib/foreman_tasks_core/runner/base.rb', line 40

def close
  # if cleanup is needed
end

#kill ⇒ Object 



36
37
38
 
# File 'lib/foreman_tasks_core/runner/base.rb', line 36

def kill
  # Override when you can kill the runner in the middle
end

#publish_data(data, type) ⇒ Object 



44
45
46
 
# File 'lib/foreman_tasks_core/runner/base.rb', line 44

def publish_data(data, type)
  @continuous_output.add_output(data, type)
end

#publish_exception(context, exception, fatal = true) ⇒ Object 



48
49
50
51
52
53
 
# File 'lib/foreman_tasks_core/runner/base.rb', line 48

def publish_exception(context, exception, fatal = true)
  logger.error("#{context} - #{exception.class} #{exception.message}:\n" + \
               exception.backtrace.join("\n"))
  @continuous_output.add_exception(context, exception)
  publish_exit_status('EXCEPTION') if fatal
end

#publish_exit_status(status) ⇒ Object 



55
56
57
 
# File 'lib/foreman_tasks_core/runner/base.rb', line 55

def publish_exit_status(status)
  @exit_status = status
end

#refresh ⇒ Object

Raises:

  • (NotImplementedError) 


32
33
34
 
# File 'lib/foreman_tasks_core/runner/base.rb', line 32

def refresh
  raise NotImplementedError
end

#run_refresh ⇒ Object 



18
19
20
21
22
23
24
25
26
 
# File 'lib/foreman_tasks_core/runner/base.rb', line 18

def run_refresh
  logger.debug('refreshing runner')
  refresh
  new_data = @continuous_output
  @continuous_output = ForemanTasksCore::ContinuousOutput.new
  if !new_data.empty? || @exit_status
    return Runner::Update.new(new_data, @exit_status)
  end
end

#start ⇒ Object

Raises:

  • (NotImplementedError) 


28
29
30
 
# File 'lib/foreman_tasks_core/runner/base.rb', line 28

def start
  raise NotImplementedError
end