From a8789e60fe586e539e5740cb25701e69eeb01348 Mon Sep 17 00:00:00 2001 From: Damien De Paoli Date: Thu, 14 Jan 2021 22:13:00 +1100 Subject: [PATCH] first thoughts on pa_job_engine - to keep overall pa_job engine state, also a pa_job_state in each action also a wait_for so we can do basic handling of jobs and dependencies --- tables.sql | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/tables.sql b/tables.sql index 23658e1..3b44ae6 100644 --- a/tables.sql +++ b/tables.sql @@ -20,13 +20,15 @@ create table person_refimg_link ( person_id integer, refimg_id integer, constraint u_prl_refimg_id unique(refimg_id) ); create table job ( - id integer, start_time timestamptz, last_update timestamptz, state varchar(128), - num_passes integer, current_pass integer, num_files integer, current_file_num integer, current_file integer, + id integer, start_time timestamptz, last_update timestamptz, state varchar(128), num_passes integer, current_pass integer, + num_files integer, current_file_num integer, current_file integer, wait_for integer, pa_job_state varchar(48), constraint pk_job_id primary key(id) ); create table joblog ( id integer, job_id integer, log_date timestamptz, log varchar, constraint pk_jl_id primary key(id), constraint fk_jl_job_id foreign key(job_id) references job(id) ); +create table pa_job_engine ( id integer, state varchar(128), num_jobs_active integer, num_jobs_complete integer, constraint pa_job_engine_id primary key(id) ); + create sequence file_id_seq; create sequence ill_id_seq; create sequence importlog_id_seq;