Changeset 37238
- Timestamp:
- Aug 12, 2014, 3:18:42 PM (12 years ago)
- Location:
- branches/eam_branches/ipp-20140717/ippToPsps/jython
- Files:
-
- 4 edited
Legend:
- Unmodified
- Added
- Removed
-
branches/eam_branches/ipp-20140717/ippToPsps/jython/batch.py
r37232 r37238 39 39 fits): 40 40 41 # print "starting the batch"42 43 # self.printline = 044 # self.testprint()45 46 41 self.readHeader = False 47 42 self.config = config … … 53 48 self.logger.infoSeparator() 54 49 self.logger.debug("Batch class constructor") 55 56 # self.testprint()57 50 58 51 # set up class variables … … 66 59 self.pspsVoTableFilePath = self.config.configDir + "tables." + batchType + ".vot" 67 60 68 # self.testprint()69 70 61 # check FITS file is ok 71 62 if self.fits: … … 106 97 if not os.path.exists(self.localOutPath): os.makedirs(self.localOutPath) 107 98 108 # self.testprint()109 110 99 # store today's date 111 100 now = datetime.datetime.now(); … … 123 112 self.logger.infoPair("Input FITS file", self.fits.getOriginalPath()) 124 113 self.logger.infoPair("Input FITS primary header", "%s cards found" % self.fits.getPrimaryHeaderCardCount()) 125 126 # self.testprint()127 114 128 115 self.logger.infoPair("Output path", self.localOutPath) … … 493 480 # get everything from table 494 481 try: 495 print "reading table from mysql ", table496 482 _table = stilts.tread(self.scratchDb.url + '#SELECT * FROM ' + table) 497 483 self.scratchDb.killLastConnectionID() -
branches/eam_branches/ipp-20140717/ippToPsps/jython/loader.py
r37232 r37238 82 82 83 83 self.skychunk.printAll() 84 print "done with loader.py init"85 84 86 85 ''' -
branches/eam_branches/ipp-20140717/ippToPsps/jython/queue.py
r37133 r37238 29 29 super(Queue, self).__init__(argv) 30 30 31 # print "inited ipptopsps"32 33 31 # create various objects 34 32 self.gpc1Db = Gpc1Db(self.logger, self.config) 35 # print "connect to gpc1"36 33 37 34 self.datastore = Datastore(self.logger, self.skychunk, self.ippToPspsDb) 38 39 print "made datastore"40 35 41 36 # connect to scratch database 42 37 self.scratchDb = ScratchDb(self.logger, self.config) 43 38 44 print "connect to scratchdb"45 46 39 try: 47 print "does this work?"48 40 self.dvoObjects = DvoObjects(self.logger, self.config, self.skychunk, self.ippToPspsDb, self.scratchDb) 49 41 except: 50 42 self.exitProgram("Unable to create instance of DvoObject") 51 43 raise 52 53 print "got objects"54 44 55 45 self.skychunk.printAll() … … 144 134 if (dec > 85): raise 145 135 146 print "dec, dD: ", dec, dD ,self.skychunk.maxDec136 # print "dec, dD: ", dec, dD ,self.skychunk.maxDec 147 137 148 138 # a given box centered at RA,DEC with (linear) size of SIDE has the following bounds … … 152 142 ra = self.skychunk.minRa + dR 153 143 154 print "ra, dR, maxRa", ra, dR, self.skychunk.maxRa144 # print "ra, dR, maxRa", ra, dR, self.skychunk.maxRa 155 145 156 146 # XXX not sure why this is not done with a for-loop... 157 147 while dec <= self.skychunk.maxDec: 158 148 while ra <= self.skychunk.maxRa: 159 print "here"160 149 # a given box centered at RA,DEC with (linear) size of SIDE has the following bounds 161 150 minRA = ra - dR … … 175 164 len(ids))) 176 165 177 print "box_id: ", box_id178 179 166 if len(ids) > 0: self.ippToPspsDb.insertPending(box_id, batchType, ids) 180 167 # print "inserted pending" -
branches/eam_branches/ipp-20140717/ippToPsps/jython/stackbatch.py
r37237 r37238 476 476 tablename = "StackModelFit" + model 477 477 478 if self.config.camera == "simtest": 479 self.logger.infoPair("Skipping table for simtest:", tablename) 480 return 481 478 482 self.logger.infoPair("Procesing table", tablename) 479 483 self.insertDvoIDs(tablename, "StackObjectThin") … … 607 611 tablename = "StackPetrosian" 608 612 613 if self.config.camera == "simtest": 614 self.logger.infoPair("Skipping table for simtest:", tablename) 615 return 616 609 617 self.logger.infoPair("Procesing table", tablename) 610 618 self.insertDvoIDs(tablename, "StackObjectThin") … … 677 685 tablename = "StackApFlx" 678 686 687 if self.config.camera == "simtest": 688 self.logger.infoPair("Skipping table for simtest:", tablename) 689 return 690 679 691 self.logger.infoPair("Procesing table", tablename) 680 692 self.insertDvoIDs(tablename, "StackObjectThin") … … 697 709 698 710 tablename = "StackApFlxFull" + version 711 712 if self.config.camera == "simtest": 713 self.logger.infoPair("Skipping table for simtest:", tablename) 714 return 699 715 700 716 self.logger.infoPair("Procesing table", tablename)
Note:
See TracChangeset
for help on using the changeset viewer.
