Class: JobRunner

Inherits:

Object

• Object
• JobRunner

show all

Defined in:

backend/app/lib/job_runner.rb

Defined Under Namespace

Classes: BackgroundJobError, JobRunnerNotFound

Class Method Summary (collapse)

• + (Object) for(job)
• + (Object) inherited(subclass)
• + (Object) register_runner(subclass)

Instance Method Summary (collapse)

• - (Object) canceled(canceled)
• - (JobRunner) initialize(job) constructor

  A new instance of JobRunner.

• - (Object) run

28
29
30
31
32
33

# File 'backend/app/lib/job_runner.rb', line 28

def initialize(job)
  @job = job
  RequestContext.open(:repo_id => @job.repo_id) do
    @json = Job.to_jsonmodel(job)
  end
end

7
8
9
10
11
12
13
14

# File 'backend/app/lib/job_runner.rb', line 7

def self.for(job)
  @runners.each do |runner|
    runner = runner.instance_for(job)
    return runner if runner
  end

  raise JobRunnerNotFound.new("No suitable runner found for #{job.job_type}")
end

23
24
25

# File 'backend/app/lib/job_runner.rb', line 23

def self.inherited(subclass)
  JobRunner.register_runner(subclass)
end

17
18
19
20

# File 'backend/app/lib/job_runner.rb', line 17

def self.register_runner(subclass)
  @runners ||= []
  @runners.unshift(subclass)
end

36
37
38
39

# File 'backend/app/lib/job_runner.rb', line 36

def canceled(canceled)
  @job_canceled = canceled
  self
end

42

# File 'backend/app/lib/job_runner.rb', line 42

def run; end