class Pallets::Backends::Base
Public Instance Methods
discard(job)
click to toggle source
Discards malformed job
# File lib/pallets/backends/base.rb, line 24 def discard(job) raise NotImplementedError end
get_context(wfid)
click to toggle source
# File lib/pallets/backends/base.rb, line 9 def get_context(wfid) raise NotImplementedError end
give_up(wfid, job, old_job)
click to toggle source
Gives up job after repeteadly failing to process it
# File lib/pallets/backends/base.rb, line 29 def give_up(wfid, job, old_job) raise NotImplementedError end
pick()
click to toggle source
Picks a job that is ready for processing
# File lib/pallets/backends/base.rb, line 5 def pick raise NotImplementedError end
reschedule_all(earlier_than)
click to toggle source
# File lib/pallets/backends/base.rb, line 33 def reschedule_all(earlier_than) raise NotImplementedError end
retry(job, old_job, at)
click to toggle source
Schedules a failed job for retry
# File lib/pallets/backends/base.rb, line 19 def retry(job, old_job, at) raise NotImplementedError end
run_workflow(wfid, jobs, jobmasks, context)
click to toggle source
# File lib/pallets/backends/base.rb, line 37 def run_workflow(wfid, jobs, jobmasks, context) raise NotImplementedError end
save(wfid, jid, job, context_buffer)
click to toggle source
Saves a job after successfully processing it
# File lib/pallets/backends/base.rb, line 14 def save(wfid, jid, job, context_buffer) raise NotImplementedError end