Contents

# -*- coding: utf-8 -*-
require 'tengine/job'

# 実行時のルートジョブネットを表すVertex
class Tengine::Job::RootJobnetActual < Tengine::Job::JobnetActual
  include Tengine::Job::Root

  has_many :executions, :inverse_of => :root_jobnet, :class_name => "Tengine::Job::Execution"


  def rerun(*args)
    options = args.extract_options!
    sender = options.delete(:sender) || Tengine::Event.default_sender
    options = options.merge({
        :retry => true,
        :root_jobnet_id => self.id,
      })
    result = Tengine::Job::Execution.new(options)
    result.target_actual_ids ||= []
    result.target_actual_ids += args.flatten
    result.safely(safemode(Tengine::Job::Execution.collection)).save!
    sender.wait_for_connection do
      sender.fire(:'start.execution.job.tengine', :properties => {
          :execution_id => result.id.to_s
        })
    end
    result
  end

  def update_with_lock(*args)
    super(*args) do
      Tengine::Job.test_harness_hook("before yield in update_with_lock")
      yield if block_given?
      Tengine::Job.test_harness_hook("after yield in update_with_lock")
    end
    Tengine::Job.test_harness_hook("after update_with_lock")
  end

end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
tengine_job-0.6.13	lib/tengine/job/root_jobnet_actual.rb
tengine_job-0.6.12	lib/tengine/job/root_jobnet_actual.rb
tengine_job-0.6.11	lib/tengine/job/root_jobnet_actual.rb
tengine_job-0.6.10	lib/tengine/job/root_jobnet_actual.rb