Sha256: 09b6c925ee18cb89213df4e736dc8dd620a589e9a29aadb3e11ecc140ae10be5
Contents?: true
Size: 856 Bytes
Versions: 6
Compression:
Stored size: 856 Bytes
Contents
module Pallets
module Backends
class Base
# Picks a job that is ready for processing
def pick
raise NotImplementedError
end
def get_context(workflow_id)
raise NotImplementedError
end
# Saves a job after successfully processing it
def save(workflow_id, job, context_buffer)
raise NotImplementedError
end
# Schedules a failed job for retry
def retry(job, old_job, at)
raise NotImplementedError
end
# Gives up job after repeteadly failing to process it
def give_up(job, old_job)
raise NotImplementedError
end
def reschedule_all(earlier_than)
raise NotImplementedError
end
def run_workflow(workflow_id, jobs_with_dependencies, context)
raise NotImplementedError
end
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems