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