Changeset 35605 for trunk/ippToPsps/jython/queue.py

Timestamp:

May 29, 2013, 2:30:34 PM (13 years ago)

Author:

heather

Message:

this is whatever is current (or was currently used) for sas14. I assume its ok

File:

• trunk/ippToPsps/jython/queue.py (modified) (6 diffs)

trunk/ippToPsps/jython/queue.py

@@ -37 +37 @@
         self.datastore = Datastore(self.logger, self.skychunk, self.ippToPspsDb)
 
-        # print "made datastore"
+        print "made datastore"
 
         # connect to scratch database
         self.scratchDb = ScratchDb(self.logger, self.config)
 
-        # print "connect to scratchdb"
+        print "connect to scratchdb"
 
         try:
@@ -50 +50 @@
             raise
 
-        # print "got objects"
+        print "got objects"
 
         self.skychunk.printAll()
@@ -62 +62 @@
     '''
     def run(self):
-
+        print "here"
         # this outer while loop simply waits a few minutes then starts queuing again (as more stuff may appear in DVO over time)
         while True:
 
             self.ippToPspsDb.removeAllBoxes()
-        
+            print "remove boxes" 
             # queue up batches that are processed but not loaded to datastore
             for batchType in self.skychunk.batchTypes: 
-
+                self.logger.infoPair("BatchType",batchType)
                 # self.logger.infoTitle("Previous failed datastore loads")
                 # self.publishAnyUnpublishedBatches(batchType)
@@ -76 +76 @@
                 # get totals for whole area to check if there is anything to do
                 processedIDs = self.ippToPspsDb.getProcessedIDs(batchType)
+                print "got processed ids"
                 consistantlyFailedIDs = self.ippToPspsDb.getConsistentlyFailedIDs(batchType)
-
+                print "got here"
                 # for object batches, get full list of stuff from Dvo
                 # XXX : need to fix 'dvo.setSkyArea' or this may not return the full list for a parallel dvo
@@ -136 +137 @@
                     if (dec > 85): raise
 
-                    # print "dec, dD: ", dec, dD
+                    print "dec, dD: ", dec, dD ,self.skychunk.maxDec
 
                     # a given box centered at RA,DEC with (linear) size of SIDE has the following bounds
-                    dR = 0.5*self.skychunk.boxSize / math.cos(math.radians(dec))
+                    #dR = 0.5*self.skychunk.boxSize / math.cos(math.radians(dec))
+                    dR = 0.5*self.skychunk.boxSize
                     ra = self.skychunk.minRa + dR
                     
-                    # print "ra, dR: ", ra, dR
+                    print "ra, dR, maxRa", ra, dR, self.skychunk.maxRa
 
                     # XXX not sure why this is not done with a for-loop...
                     while dec <= self.skychunk.maxDec:
                         while ra <= self.skychunk.maxRa:
-            
+                            
                            # a given box centered at RA,DEC with (linear) size of SIDE has the following bounds
                            minRA  = ra  - dR
@@ -175 +177 @@
                         if (dec > 85): raise
 
-                        dR = 0.5*self.skychunk.boxSize / math.cos(math.radians(dec))
+                        #dR = 0.5*self.skychunk.boxSize / math.cos(math.radians(dec))
+                        dR = 0.5*self.skychunk.boxSize
                         ra = self.skychunk.minRa + dR