Module: Tengine::Job::Runtime::Signal::Transmittable

Included in:
Edge, Vertex
Defined in:
lib/tengine/job/runtime/signal.rb

Instance Method Summary collapse

Instance Method Details

#activate(signal) ⇒ Object

Raises:

  • (NotImplementedError) 


192
 
# File 'lib/tengine/job/runtime/signal.rb', line 192

def activate(signal); raise NotImplementedError; end

#complete_origin_edge(signal, options = {}) ⇒ Object 



194
195
196
197
198
199
200
201
202
203
204
 
# File 'lib/tengine/job/runtime/signal.rb', line 194

def complete_origin_edge(signal, options = {})
  origin_edge = signal.cache(signal.paths.last)
  origin_edge ||= signal.cache(prev_edges.first)
  begin
    return if options[:except_closed] && origin_edge.closed?
    origin_edge.complete(signal)
  rescue Exception => e
    puts "[#{e.class.name}] #{e.message}\nsignal.paths: #{@paths.inspect}"
    raise e
  end
end

#transmit(signal) ⇒ Object

includeするモジュールは以下のメソッドを定義しなければならない

Raises:

  • (NotImplementedError) 


191
 
# File 'lib/tengine/job/runtime/signal.rb', line 191

def transmit(signal); raise NotImplementedError; end