IPP Software Navigation Tools IPP Links Communication Pan-STARRS Links

Changeset 33119 for trunk/ippTools/share


Ignore:
Timestamp:
Jan 19, 2012, 3:39:28 PM (14 years ago)
Author:
bills
Message:

Add support for pstampJobs that depend on other jobs. This will be used to implement
working dependency checking for detectability queries

Location:
trunk/ippTools/share
Files:
3 edited

Legend:

Unmodified
Added
Removed
  • trunk/ippTools/share/pstamptool_pendingjob.sql

    r27856 r33119  
    1 SELECT pstampJob.*,
    2     IFNULL(Label.priority, 10000) AS priority
     1SELECT * FROM
     2(SELECT pstampJob.*,
     3    IFNULL(Label.priority, 10000) AS priority,
     4    0 AS myParent,
     5    0 AS runningChildren
    36FROM pstampJob
    47    JOIN pstampRequest USING(req_id)
     
    912    AND pstampJob.state = 'run'
    1013    AND pstampJob.fault = 0
     14    AND NOT is_parent
    1115    AND (dep_id = 0 OR pstampDependent.state = 'full')
    1216    AND (Label.active OR Label.active IS NULL)
     17    -- where hook 1 %s
     18UNION
     19SELECT * FROM
     20  (SELECT pstampJob.*,
     21        IFNULL(Label.priority, 10000) AS priority
     22    FROM pstampJob
     23        JOIN pstampRequest USING(req_id)
     24        LEFT JOIN pstampDependent USING(dep_id)
     25        LEFT JOIN Label ON pstampRequest.label = Label.label
     26    WHERE pstampRequest.state = 'run'
     27        AND pstampRequest.fault = 0
     28        AND pstampJob.state = 'run'
     29        AND pstampJob.fault = 0
     30        AND is_parent
     31        AND (dep_id = 0 OR pstampDependent.state = 'full')
     32        AND (Label.active OR Label.active IS NULL)
     33        -- where hook 2 %s
     34    ) as parentJob
     35    LEFT JOIN
     36    (SELECT parent_id AS myParent,
     37            count(job_id) as runningChildren
     38        FROM pstampRequest JOIN pstampJob USING(req_id)
     39        WHERE pstampRequest.state ='run'
     40            AND pstampJob.state = 'run'
     41            AND pstampJob.parent_id
     42        GROUP BY parent_id
     43    ) as childJobs
     44    ON childJobs.myParent = parentJob.job_id
     45    WHERE runningChildren IS NULL
     46) AS theQuery
     47
     48
  • trunk/ippTools/share/pstamptool_stopdependentjob.sql

    r29248 r33119  
    55SET pstampJob.state = 'stop',
    66    pstampJob.fault = %d,
    7     pstampDependent.fault = %d
     7    pstampDependent.fault = %d,
     8    pstampDependent.state = '%s'
    89WHERE pstampJob.state = 'run'
    910    AND pstampDependent.state = 'new'
  • trunk/ippTools/share/pxadmin_create_tables.sql

    r33032 r33119  
    14421442        fault SMALLINT,
    14431443        PRIMARY KEY(req_id),
    1444         KEY(req_id)
     1444        KEY(req_id),
     1445        KEY(state),
     1446        KEY(fault),
     1447        KEY(label)
    14451448) ENGINE=innodb DEFAULT CHARSET=latin1;
    14461449
     
    14561459        options BIGINT,
    14571460        dep_id BIGINT,
     1461        fault_count INT,
     1462        parent_id BIGINT DEFAULT NULL,
     1463        is_parent TINYINT DEFAULT 0,
    14581464        PRIMARY KEY(job_id, req_id),
    14591465        KEY(job_id),
     1466        KEY(req_id),
     1467        KEY(state),
     1468        KEY(fault),
     1469        KEY(dep_id),
     1470        KEY(parent_id),
     1471        KEY(is_parent),
    14601472        FOREIGN KEY(req_id) REFERENCES pstampRequest(req_id)
    14611473) ENGINE=innodb DEFAULT CHARSET=latin1;
     
    14681480        component  VARCHAR(64),
    14691481        imagedb    VARCHAR(64),
     1482        outdir     VARCHAR(255),
    14701483        rlabel     VARCHAR(64),
    14711484        need_magic TINYINT,
    1472         outdir     VARCHAR(255),
    14731485        fault      SMALLINT,
    14741486        fault_count INT,
     
    14771489        KEY(stage),
    14781490        KEY(stage_id),
     1491        KEY(component),
     1492        KEY(imagedb),
    14791493        KEY(fault)
    14801494) ENGINE=innodb DEFAULT CHARSET=latin1;
Note: See TracChangeset for help on using the changeset viewer.