Changeset 39148 for trunk/ippToPsps/jython/dvo.py
- Timestamp:
- Nov 16, 2015, 3:00:27 PM (11 years ago)
- File:
-
- 1 edited
-
trunk/ippToPsps/jython/dvo.py (modified) (7 diffs)
Legend:
- Unmodified
- Added
- Removed
-
trunk/ippToPsps/jython/dvo.py
r38995 r39148 72 72 # response = raw_input("(y/n) ") 73 73 # if response == "y": 74 self.resetAllTables() 74 self.resetAllTables() ## called if we need to change DVOs 75 75 76 76 ''' … … 95 95 self.correctDvo = True 96 96 if not self.loadSkyTable(): 97 self.correctDvo = False 98 return 99 if not self.loadPhotcodes(): 100 self.correctDvo = False 101 return 102 if not self.loadImages(): 97 103 self.correctDvo = False 98 104 return … … 298 304 return False 299 305 300 # update the two meta tables, Images andSkyTable301 self.loadSkyTable() 306 # update the SkyTable 307 self.loadSkyTable() ## in setSkyArea 302 308 303 309 # set bounding-box coords … … 508 514 def sync(self): 509 515 510 # go no further if we've already partly ingested a different DVO 511 if not self.correctDvo: return False 512 513 # check we have something to do 514 if len(self.regionsToPurge) < 1 and len(self.regionsToIngest) < 1: 515 self.logger.infoPair("Nothing to ingest or purge", "finished ingest") 516 return True 517 518 # make sure we have an up-to-date Images table 519 self.loadImages() 520 521 # purge stuff 522 self.purgeRegions(self.regionsToPurge) 523 524 totalRegions = len(self.regionsToIngest) 525 if totalRegions > 0: self.logger.infoSeparator() 526 527 # now loop through all regions and ingest to MySQL 528 ingestedRegionsCount = 0 529 regionCount = 1 530 for region in self.regionsToIngest: 531 532 self.logger.infoTitle("Region %d of %d: %s" % (regionCount, totalRegions, region)) 533 if self.ingestRegion(region): ingestedRegionsCount += 1 534 regionCount += 1 535 536 self.logger.infoSeparator() 537 self.logger.infoPair("Ingested", "%d DVO regions (out of %d)" % (ingestedRegionsCount, len(self.regionsToIngest))) 538 539 # update lists after attempted sync 540 self.setSkyArea(self.minRa, self.maxRa, self.minDec, self.maxDec) 541 self.printSummary() 516 print "---- sync is disabled ----" 517 os._exit(3) 518 519 ### XXX # go no further if we've already partly ingested a different DVO 520 ### XXX if not self.correctDvo: return False 521 ### XXX 522 ### XXX # check we have something to do 523 ### XXX if len(self.regionsToPurge) < 1 and len(self.regionsToIngest) < 1: 524 ### XXX self.logger.infoPair("Nothing to ingest or purge", "finished ingest") 525 ### XXX return True 526 ### XXX 527 ### XXX # make sure we have an up-to-date Images table 528 ### XXX self.loadImages() 529 ### XXX 530 ### XXX # purge stuff 531 ### XXX self.purgeRegions(self.regionsToPurge) 532 ### XXX 533 ### XXX totalRegions = len(self.regionsToIngest) 534 ### XXX if totalRegions > 0: self.logger.infoSeparator() 535 ### XXX 536 ### XXX # now loop through all regions and ingest to MySQL 537 ### XXX ingestedRegionsCount = 0 538 ### XXX regionCount = 1 539 ### XXX for region in self.regionsToIngest: 540 ### XXX 541 ### XXX self.logger.infoTitle("Region %d of %d: %s" % (regionCount, totalRegions, region)) 542 ### XXX if self.ingestRegion(region): ingestedRegionsCount += 1 543 ### XXX regionCount += 1 544 ### XXX 545 ### XXX self.logger.infoSeparator() 546 ### XXX self.logger.infoPair("Ingested", "%d DVO regions (out of %d)" % (ingestedRegionsCount, len(self.regionsToIngest))) 547 ### XXX 548 ### XXX # update lists after attempted sync 549 ### XXX self.setSkyArea(self.minRa, self.maxRa, self.minDec, self.maxDec) 550 ### XXX self.printSummary() 542 551 543 552 return True … … 688 697 689 698 # make sure we have an up-to-date Images table 690 self.loadImages() 699 self.loadImages() # this is in nativeIngestDetections (remove?) 691 700 692 701 # the box dimensions are the area used to select the items of … … 698 707 dD_border = self.skychunk.BORDER 699 708 700 # This is a terrible hack but I'm tired of it taking a decade to ingest the FW skycells.709 # This is a terrible hack but I'm tired of it taking a decade to ingest the FW skycells. 701 710 702 711 #if self.batchType == "ST": … … 706 715 # dR_border = .4 / math.cos(math.radians(boxDim['DEC'])) 707 716 # dD_border = .4 708 709 710 717 711 718 minRA = boxDim['minRA'] - dR_border
Note:
See TracChangeset
for help on using the changeset viewer.
