module Tengine::Job::Runtime::Signal::Transmittable
Public Instance Methods
activate(signal)
click to toggle source
# File lib/tengine/job/runtime/signal.rb, line 191 def activate(signal); raise NotImplementedError; end
complete_origin_edge(signal, options = {})
click to toggle source
# File lib/tengine/job/runtime/signal.rb, line 193 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)
click to toggle source
includeするモジュールは以下のメソッドを定義しなければならない
# File lib/tengine/job/runtime/signal.rb, line 190 def transmit(signal); raise NotImplementedError; end