class ResqueJobsTree::Job

Public Class Methods

perform(*args) click to toggle source
# File lib/resque_jobs_tree/job.rb, line 5
def perform *args
  node(*args).perform
end

Protected Class Methods

after_perform_run_callback(*args) click to toggle source
# File lib/resque_jobs_tree/job.rb, line 15
def after_perform_run_callback *args
  node(*args).after_perform
end
before_perform_run_callback(*args) click to toggle source
# File lib/resque_jobs_tree/job.rb, line 11
def before_perform_run_callback *args
  node(*args).before_perform
end
node(tree_name, job_name, *resources_arguments) click to toggle source
# File lib/resque_jobs_tree/job.rb, line 23
def node tree_name, job_name, *resources_arguments
  node_definition = ResqueJobsTree.find(tree_name).find job_name
  resources       = ResqueJobsTree::ResourcesSerializer.instancize resources_arguments
  node = node_definition.spawn(resources)
  if node.exists?
    node
  else
    puts "Warning, the job #{node.definition.tree.name}##{node.definition.name}##{node.resources.inspect} " \
         "doesn't exist. Cleaning-up."
    node.cleanup
    FakeNode.new
  end
end
on_failure_run_callback(exception, *args) click to toggle source
# File lib/resque_jobs_tree/job.rb, line 19
def on_failure_run_callback exception, *args
  node(*args).on_failure
end