Changeset 36727

Timestamp:

May 2, 2014, 6:47:15 PM (12 years ago)

Author:

heather

Message:

stack batch work

File:

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

trunk/ippToPsps/jython/stackbatch.py

@@ -619 +619 @@
         self.logger.infoPair("Procesing table", "StackObject")
         
-        
-
-
-
-
         self.logger.infoPair("inserting non-filter dependent items into", "StackObject")
 
@@ -749 +744 @@
                    FROM " + f + "SkyChip_psf"
              
-
-             self.scratchDb.execute(sql)
-
+             try:
+                 self.scratchDb.execute(sql)
+             except:
+                 self.logger.errorPair('failed sql',sql)
+                 return
              #it is possible to drop some detections from dvo (that are present in the cmf). when that happens we get a 0 for objid
         #we drop those...
 
+        self.logger.infoPair("Deleting", "entries with StackObject.objID = 0")
         sql="DELETE FROM StackObject where objID = 0"
-        self.scratchDb.execute(sql)
-        self.logger.infoPair("Deleting", "entries with StackObject.objID = 0")
-        
-        self.scratchDb.updateAllRows("StackObject", "surveyID", str(self.surveyID))
-        
+        try:
+            self.scratchDb.execute(sql)
+        except:
+            self.logger.errorPair('failed sql',sql)
+            return
+        
+        try:
+            self.scratchDb.updateAllRows("StackObject", "surveyID", str(self.surveyID))
+        except:
+            self.logger.errorPair('failed update surveyID on','StackObject')
+            
 #        self.scratchDb.updateFilterID("StackObject", f+".00000")
         
@@ -791 +795 @@
         ### XXX this should not be a DEEP_STACK only case...
         if False and self.stackType == "DEEP_STACK": 
-
+            ## need to do for all filters?
             #if deep stack and instFlux = null and err not null
             sql = "UPDATE StackObject AS a, SkyChip_psf AS b \
@@ -931 +935 @@
 
         self.scratchDb.updateAllRows("StackApFlx", "surveyID", str(self.surveyID))
-        self.scratchDb.updateFilterID("StackApFlx", self.filter)
         self.scratchDb.updateAllRows("StackApFlx", "dataRelease", str(self.skychunk.dataRelease))
-        self.scratchDb.updateAllRows("StackApFlx", "activeFlag", "0")
-        ##self.updateStackMetaID("StackApFlx")
         self.updateStackTypeID("StackApFlx")
         self.updateDvoIDs("StackApFlx")