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)¶

event¶

execute()¶

execute_job_action(job_action)¶

finish()¶

get_schedule_args()¶

id¶

job_doc_status¶

kill()¶

process_event(job_doc)¶

remove()¶

result¶

static save_action_to_file(action, f)¶

schedule()¶

schedule_cron_fields¶

schedule_date¶

schedule_end_date¶

schedule_interval¶

schedule_start_date¶

scheduled¶

session_id¶

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)¶