- Timestamp:
- Jul 29, 2014, 9:52:00 AM (12 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
branches/eam_branches/ipp-20140717/ippToPsps/jython/queue.py
r37129 r37133 63 63 ''' 64 64 def run(self): 65 print "here"65 self.logger.info("------------- starting queue.run -----------------") 66 66 # this outer while loop simply waits a few minutes then starts queuing again (as more stuff may appear in DVO over time) 67 67 while True: 68 68 69 69 self.ippToPspsDb.removeAllBoxes() 70 print "remove boxes" 70 71 71 # queue up batches that are processed but not loaded to datastore 72 72 for batchType in self.skychunk.batchTypes: … … 77 77 # get totals for whole area to check if there is anything to do 78 78 processedIDs = self.ippToPspsDb.getProcessedIDs(batchType) 79 print "got processed ids"80 79 consistantlyFailedIDs = self.ippToPspsDb.getConsistentlyFailedIDs(batchType) 81 print "got here" 80 82 81 # for object batches, get full list of stuff from Dvo 83 82 # XXX : need to fix 'dvo.setSkyArea' or this may not return the full list for a parallel dvo 84 #for object-like batches, info comes from dvo 83 84 # for object-like batches, info comes from dvo 85 85 if (batchType == "OB" or batchType =="DO" or batchType =="FO"): 86 86 self.dvoObjects.setSkyArea(
Note:
See TracChangeset
for help on using the changeset viewer.
