Changeset 28082 for trunk/ippTools/share/warptool_towarped.sql

Timestamp:

May 24, 2010, 7:18:05 PM (16 years ago)

Author:

bills

Message:

order pending files by priority. Works but needs optimization.

File:

• trunk/ippTools/share/warptool_towarped.sql (modified) (7 diffs)

trunk/ippTools/share/warptool_towarped.sql

@@ -12 +12 @@
     workdir,
     magicked,
-    path_base
+    path_base,
+    priority
 FROM (
-    SELECT DISTINCT
+    (SELECT DISTINCT
         warpSkyCellMap.warp_id,
         warpImfile.warp_skyfile_id,
@@ -27 +28 @@
         warpRun.workdir,
         chipRun.magicked,
-        CAST(NULL AS CHAR(255)) AS path_base
+        CAST(NULL AS CHAR(255)) AS path_base,
+        IFNULL(Label.priority, 10000) AS priority
     FROM warpRun
     JOIN warpSkyCellMap
@@ -50 +52 @@
     LEFT JOIN warpMask
         ON warpRun.label = warpMask.label
+    LEFT JOIN Label ON warpRun.label = Label.label
     WHERE
         warpRun.state = 'new'
@@ -60 +63 @@
         AND warpMask.label IS NULL
         AND warpSkyCellMap.fault = 0
+        AND (Label.active OR Label.active IS NULL)
         -- where hook 1 %s
         -- limit hook 1 %s
+    )
 UNION
-    SELECT
+    (SELECT
         warpSkyCellMap.warp_id,
         warpImfile.warp_skyfile_id,
@@ -76 +81 @@
         warpRun.workdir,
         MIN(chipProcessedImfile.magicked) AS magicked,
-        warpSkyfile.path_base
+        warpSkyfile.path_base,
+        IFNULL(Label.priority, 10000) AS priority
     FROM warpRun
     JOIN warpImfile USING(warp_id)
@@ -86 +92 @@
     JOIN rawExp USING(exp_id)
     LEFT JOIN chipProcessedImfile USING(chip_id, class_id)
+    LEFT JOIN Label ON warpRun.label = Label.label
     WHERE warpRun.state = 'update'
         AND warpSkyfile.data_state = 'update'
@@ -94 +101 @@
         -- this blocks processing until all the chip inputs have been destreaked
         AND (warpSkyfile.magicked = 0 OR chipProcessedImfile.magicked >= 0)
+        AND (Label.active OR Label.active IS NULL)
         -- where hook 2 %s
     GROUP BY warp_id, skycell_id
     HAVING COUNT(warpSkyCellMap.class_id) = COUNT(chipProcessedImfile.class_id)
     -- limit hook 2 %s
+    )
 ) as towarped
-