freezer.scheduler.scheduler_job module

class freezer.scheduler.scheduler_job.Job(scheduler, executable, job_doc)

Bases: object

ABORTED_RESULT = 'aborted'
ABORT_EVENT = 'abort'
COMPLETED_STATUS = 'completed'
FAIL_RESULT = 'fail'
NO_EVENT = ''
REMOVED_STATUS = 'removed'
REMOVE_EVENT = 'remove'
RUNNING_STATUS = 'running'
SCHEDULED_STATUS = 'scheduled'
START_EVENT = 'start'
STOP_EVENT = 'stop'
STOP_STATUS = 'stop'
SUCCESS_RESULT = 'success'
TIME_NULL = -1
can_be_removed()
contains_exec()
static create(scheduler, executable, job_doc)
end_session(result)
property event
execute()
execute_job_action(job_action)
finish()
get_schedule_args()
property id
property job_doc_status
kill()
process_event(job_doc)
remove()
property result
static save_action_to_file(action, f)
schedule()
property schedule_cron_fields
property schedule_date
property schedule_end_date
property schedule_interval
property schedule_start_date
property scheduled
property session_id
property session_tag
start_session()
terminate()
unschedule()
update_job_schedule_doc(**kwargs)

Updates the job_schedule section of the job doc with the provided keyword args. No checks about accepted key/values are being made here since they may vary in the future.

Parameters

kwargs – keyword args to add

Returns

None

upload_metadata(metadata_string)
class freezer.scheduler.scheduler_job.RunningState

Bases: object

static abort(job, doc)
static remove(job)
static start(job, doc)
static stop(job, doc)
class freezer.scheduler.scheduler_job.ScheduledState

Bases: object

static abort(job, doc)
static remove(job)
static start(job, doc)
static stop(job, doc)
class freezer.scheduler.scheduler_job.StopState

Bases: object

static abort(job, doc)
static remove(job)
static start(job, doc)
static stop(job, doc)