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