| @@ -115,7 +115,7 class AMISRReader(ProcessingUnit): | |||
|
|
115 | 115 | self.searchFilesOnLine(path, startDate, endDate, startTime,endTime,walk) |
|
|
116 | 116 | |
|
|
117 | 117 | if not(self.filenameList): |
|
|
118 |
|
|
|
|
118 | raise schainpy.admin.SchainWarning("There is no files into the folder: %s"%(path)) | |
|
|
119 | 119 | sys.exit() |
|
|
120 | 120 | |
|
|
121 | 121 | self.fileIndex = 0 |
| @@ -135,7 +135,7 class AMISRReader(ProcessingUnit): | |||
|
|
135 | 135 | if self.isConfig and (not self.flagNoMoreFiles): |
|
|
136 | 136 | newShape = fp.get('Raw11/Data/Samples/Data').shape[1:] |
|
|
137 | 137 | if self.dataShape != newShape and newShape != None: |
|
|
138 |
|
|
|
|
138 | raise schainpy.admin.SchainError("NEW FILE HAS A DIFFERENT SHAPE: ") | |
|
|
139 | 139 | print(self.dataShape,newShape,"\n") |
|
|
140 | 140 | return 0 |
|
|
141 | 141 | else: |
| @@ -411,7 +411,7 class AMISRReader(ProcessingUnit): | |||
|
|
411 | 411 | self.fileIndex += 1 |
|
|
412 | 412 | except: |
|
|
413 | 413 | self.flagNoMoreFiles = 1 |
|
|
414 | print("No more Files") | |
|
|
414 | raise schainpy.admin.SchainError('No more files to read') | |
|
|
415 | 415 | return 0 |
|
|
416 | 416 | |
|
|
417 | 417 | self.flagIsNewFile = 1 |
| @@ -285,10 +285,16 class HDFReader(Reader, ProcessingUnit): | |||
|
|
285 | 285 | self.dataOut.flagNoData = False |
|
|
286 | 286 | self.blockIndex += 1 |
|
|
287 | 287 | |
|
|
288 | if self.blockIndex == 1: | |
|
|
288 | 289 | log.log("Block No. {}/{} -> {}".format( |
|
|
289 | 290 | self.blockIndex, |
|
|
290 | 291 | self.blocksPerFile, |
|
|
291 | 292 | self.dataOut.datatime.ctime()), self.name) |
|
|
293 | else: | |
|
|
294 | log.log("Block No. {}/{} ".format( | |
|
|
295 | self.blockIndex, | |
|
|
296 | self.blocksPerFile),self.name) | |
|
|
297 | ||
|
|
292 | 298 | |
|
|
293 | 299 | return |
|
|
294 | 300 | |
| @@ -633,8 +639,10 class HDFWriter(Operation): | |||
|
|
633 | 639 | |
|
|
634 | 640 | self.fp.flush() |
|
|
635 | 641 | self.blockIndex += 1 |
|
|
642 | if self.blockIndex == 1: | |
|
|
643 | log.log('Block No. {}/{} --> {}'.format(self.blockIndex, self.blocksPerFile,self.dataOut.datatime.ctime()), self.name) | |
|
|
644 | else: | |
|
|
636 | 645 | log.log('Block No. {}/{}'.format(self.blockIndex, self.blocksPerFile), self.name) |
|
|
637 | ||
|
|
638 | 646 | return |
|
|
639 | 647 | |
|
|
640 | 648 | def closeFile(self): |
General Comments 0
You need to be logged in to leave comments.
Login now