Changeset 31298 for trunk/ippToPsps/jython/stackbatch.py

Timestamp:

Apr 15, 2011, 1:51:38 PM (15 years ago)

Author:

rhenders

Message:

Added some try/catch blocks for safety; now deleting all tables before processing begins

File:

• trunk/ippToPsps/jython/stackbatch.py (modified) (10 diffs)

trunk/ippToPsps/jython/stackbatch.py

@@ -22 +22 @@
                "stack", 
                inputFile, 
-               "ThreePi") # TODO
+               "MD04") # TODO
 
        self.logger.info("StackBatch constructor. Creating batch from: '" + inputFile + "'")
 
+       # delete PSPS tables
+       self.dropTable("StackMeta")
+       self.dropTable("StackDetection")
+       self.dropTable("StackModelFit")
+       self.dropTable("StackApFlx")
+       self.dropTable("StackToImage")
+
+       # delete IPP tables
+       self.dropTable("SkyChip_psf")
+       self.dropTable("SkyChip_xsrc")
+       self.dropTable("SkyChip_xfit")
+       self.dropTable("SkyChip_xrad")
+
        # obs time makes no sense except for nightly stacks
+       self.logger.info("Stack type: " + self.header['STK_TYPE'])
        if self.header['STK_TYPE'] != "NIGHTLY_STACK": self.header['MJD-OBS'] = "-999"
 
@@ -324 +338 @@
         self.updateDataRelease("StackDetection")
         self.updateStackTypeID("StackDetection")
+        self.updateDvoIDs("StackDetection")
 
     '''
@@ -336 +351 @@
                DISTINCT IPP_IDET \
                FROM SkyChip_xrad"
-        self.localStmt.execute(sql)
+
+        try:
+            self.localStmt.execute(sql)
+        except: return
 
         # TODO temporarily loading 1st convolved fluxes into unconvolved fields
@@ -364 +382 @@
         self.updateDataRelease("StackApFlx")
         self.updateStackTypeID("StackApFlx")
+        self.updateDvoIDs("StackApFlx")
 
     '''
@@ -373 +392 @@
         # insert all the detections
         sql = "INSERT INTO StackModelFit (ippDetectID) SELECT DISTINCT IPP_IDET from SkyChip_xfit"
-        self.localStmt.execute(sql)
+        try:
+            self.localStmt.execute(sql)
+        except:
+            return
+
 
         # populate model parameters
@@ -388 +411 @@
         self.updateDataRelease("StackModelFit")
         self.updateStackTypeID("StackModelFit")
+        self.updateDvoIDs("StackModelFit")
 
     '''
@@ -420 +444 @@
 
     '''
+    Temporary hack to fudge some object IDs
     '''
     def fudgeIDs(self):
@@ -450 +475 @@
         self.setMinMaxObjID("StackDetection")
 
+
     '''
     Does the processing, i.e. pulling stuff from IPP tables into PSPS tables
     '''
     def populatePspsTables(self):
+
+        self.getIDsFromDVO(self.header['SOURCEID'], self.header['IMAGEID'])
 
         self.populateStackMeta()
@@ -461 +489 @@
         self.populateStackToImage()
 
+        self.setMinMaxObjID("StackDetection")
+
 
 logging.config.fileConfig("logging.conf")
 logger = logging.getLogger("stackbatch")
 logger.info("Starting")
-sky_id = 299 # TODO
+sky_id = 689 # TODO
 gpc1Db = Gpc1Db(logger)
 cmfFiles = gpc1Db.getStackStageCmfs(sky_id)
@@ -477 +507 @@
     stackBatch.importIppTables("")
     stackBatch.populatePspsTables()
-    stackBatch.fudgeIDs()
     stackBatch.reportNullsInAllPspsTables(False)
-    #    stackBatch.replaceAllPspsNulls("-999")  
     stackBatch.exportPspsTablesToFits()
     stackBatch.writeBatchManifest()