Class: Remi::Job::SubJob

Inherits:
Object
  • Object
show all
Defined in:
lib/remi/job/sub_job.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(context = nil, name: 'UNDEFINED SubJob', **kargs, &block) ⇒ SubJob

Returns a new instance of SubJob.



4
5
6
7
8
 
# File 'lib/remi/job/sub_job.rb', line 4

def initialize(context=nil, name: 'UNDEFINED SubJob', **kargs, &block)
  @context = context
  @name = name
  @block = block
end

Instance Attribute Details

#context ⇒ Object

Returns the value of attribute context.



10
11
12
 
# File 'lib/remi/job/sub_job.rb', line 10

def context
  @context
end

#name ⇒ Object

Returns the value of attribute name.



10
11
12
 
# File 'lib/remi/job/sub_job.rb', line 10

def name
  @name
end

Instance Method Details

#dsl_return ⇒ Object

Raises:

  • (ArgumentError) 


12
13
14
15
16
 
# File 'lib/remi/job/sub_job.rb', line 12

def dsl_return
  result = Dsl.dsl_return(self, @context, &@block)
  raise ArgumentError, "SubJob DSL must return a Remi::Job" unless result.is_a? Job
  result
end

#execute ⇒ Object 



26
27
28
 
# File 'lib/remi/job/sub_job.rb', line 26

def execute
  execute! unless @executed
end

#execute! ⇒ Object 



30
31
32
33
34
 
# File 'lib/remi/job/sub_job.rb', line 30

def execute!
  result = sub_job.execute
  @executed = true
  result
end

#execute_transforms ⇒ Object 



36
37
38
 
# File 'lib/remi/job/sub_job.rb', line 36

def execute_transforms
  sub_job.execute(:transforms)
end

#fields(data_subject) ⇒ Object 



22
23
24
 
# File 'lib/remi/job/sub_job.rb', line 22

def fields(data_subject)
  sub_job.send(data_subject).dsl_eval.fields
end

#sub_job ⇒ Object 



18
19
20
 
# File 'lib/remi/job/sub_job.rb', line 18

def sub_job
  @sub_job ||= dsl_return
end