CREATESCHEMAIF NOT EXISTS schedule;

SET search_path TO schedule;

CREATETYPEjob_statusAS ENUM ('working','done','error');

CREATETYPEjob_status_tAS ENUM ('working','done','error');

CREATETYPEjob_at_status_tAS ENUM ('submitted','processing','done');

CREATETABLEat_jobs_submitted(

idSERIALPRIMARY KEY,

onrollbacktext,-- statement on ROLLBACK

next_time_statementtext,-- statement to calculate next start time

max_instancesint,-- the number of instances run at the same time

statusjob_status,-- status of job

statusjob_status_t,-- status of job

messagetext-- error message if one

);

AFTERUPDATEON cron

FOR EACH ROW EXECUTE PROCEDURE on_cron_update();

id, node, name, comments, atas run_after,

do_sqlas query, params, depends_on, executoras run_as, attempt,

resubmit_limit, postponeas max_wait_interval,

max_run_timeas max_duration, submit_time,

start_time, statusas is_success, reasonas error, done_time,

'done'::job_at_status_t status

FROMschedule.at_jobs_donewhere owner=session_user

id, node, name, comments, atas run_after,

do_sqlas query, params, depends_on, executoras run_as, attempt,

resubmit_limit, postponeas max_wait_interval,

max_run_timeas max_duration, submit_time, start_time,

NULLas is_success,NULLas error,NULLas done_time,

'processing'::job_at_status_t status

FROM ONLYschedule.at_jobs_processwhere owner=session_user

id, node, name, comments, atas run_after,

do_sqlas query, params, depends_on, executoras run_as, attempt,

resubmit_limit, postponeas max_wait_interval,

max_run_timeas max_duration, submit_time,

NULLas start_time,NULLas is_success,NULLas error,

NULLas done_time,

'submitted'::job_at_status_t status

FROM ONLYschedule.at_jobs_submittedwhere owner=session_user;

id, node, name, comments, atas run_after,

do_sqlas query, params, depends_on, executoras run_as, owner,

attempt, resubmit_limit, postponeas max_wait_interval,

max_run_timeas max_duration, submit_time,

start_time, statusas is_success, reasonas error, done_time,

'processing'::job_at_status_t status

FROMschedule.at_jobs_done

id, node, name, comments, atas run_after,

do_sqlas query, params, depends_on, executoras run_as, owner,

attempt, resubmit_limit, postponeas max_wait_interval,

max_run_timeas max_duration, submit_time, start_time,

NULLas is_success,NULLas error,NULLas done_time,

'processing'::job_at_status_t status

FROM ONLYschedule.at_jobs_process

id, node, name, comments, atas run_after,

do_sqlas query, params, depends_on, executoras run_as, owner,

attempt, resubmit_limit, postponeas max_wait_interval,

max_run_timeas max_duration, submit_time,

NULLas start_time,NULLas is_success,NULLas error,

NULLas done_time,

'submitted'::job_at_status_t status

FROM ONLYschedule.at_jobs_submitted;

GRANT USAGEON SCHEMA schedule TO public;

GRANTSELECTONschedule.job_status TO public;

RESET search_path;