@@ -734,7 +734,7 class RTIPlot(Plot): | |||||
734 | ax.plot_noise = self.pf_axes[n].plot(numpy.repeat(data['noise'][n], len(self.y)), self.y, |
|
734 | ax.plot_noise = self.pf_axes[n].plot(numpy.repeat(data['noise'][n], len(self.y)), self.y, | |
735 | color="k", linestyle="dashed", lw=1)[0] |
|
735 | color="k", linestyle="dashed", lw=1)[0] | |
736 | else: |
|
736 | else: | |
737 |
|
|
737 | ax.collections.remove(ax.collections[0]) # error while running in 3.12 | |
738 | ax.plt = ax.pcolormesh(x, y, z[n].T, |
|
738 | ax.plt = ax.pcolormesh(x, y, z[n].T, | |
739 | vmin=self.zmin, |
|
739 | vmin=self.zmin, | |
740 | vmax=self.zmax, |
|
740 | vmax=self.zmax, |
@@ -685,7 +685,6 class AMISRReader(ProcessingUnit): | |||||
685 | #self.__firstFile = False |
|
685 | #self.__firstFile = False | |
686 |
|
686 | |||
687 | self.dataset,self.timeset = self.readData() |
|
687 | self.dataset,self.timeset = self.readData() | |
688 |
|
||||
689 | if self.endDate!=None: |
|
688 | if self.endDate!=None: | |
690 | endDateTime_Reader = datetime.datetime.combine(self.endDate,self.endTime) |
|
689 | endDateTime_Reader = datetime.datetime.combine(self.endDate,self.endTime) | |
691 | time_str = self.amisrFilePointer.get('Time/RadacTimeString') |
|
690 | time_str = self.amisrFilePointer.get('Time/RadacTimeString') | |
@@ -700,6 +699,7 class AMISRReader(ProcessingUnit): | |||||
700 | if self.flag_ignoreFiles and (startDateTime_File >= self.ignStartDateTime and startDateTime_File <= self.ignEndDateTime): |
|
699 | if self.flag_ignoreFiles and (startDateTime_File >= self.ignStartDateTime and startDateTime_File <= self.ignEndDateTime): | |
701 | print("Ignoring...") |
|
700 | print("Ignoring...") | |
702 | self.flag_standby = True |
|
701 | self.flag_standby = True | |
|
702 | self.profileIndex = 99999999999999999 | |||
703 | return 1 |
|
703 | return 1 | |
704 | self.flag_standby = False |
|
704 | self.flag_standby = False | |
705 |
|
705 | |||
@@ -721,7 +721,6 class AMISRReader(ProcessingUnit): | |||||
721 | if self.flagNoMoreFiles: |
|
721 | if self.flagNoMoreFiles: | |
722 | self.dataOut.flagNoData = True |
|
722 | self.dataOut.flagNoData = True | |
723 | return 0 |
|
723 | return 0 | |
724 |
|
||||
725 | if self.profileIndex >= (self.newProfiles*self.nblocks): # |
|
724 | if self.profileIndex >= (self.newProfiles*self.nblocks): # | |
726 | #if self.__hasNotDataInBuffer(): |
|
725 | #if self.__hasNotDataInBuffer(): | |
727 | if not (self.readNextFile(self.online)): |
|
726 | if not (self.readNextFile(self.online)): | |
@@ -763,7 +762,7 class AMISRReader(ProcessingUnit): | |||||
763 | # print("kamisr: ",self.dataOut.utctime) |
|
762 | # print("kamisr: ",self.dataOut.utctime) | |
764 |
|
763 | |||
765 | self.profileIndex += 1 |
|
764 | self.profileIndex += 1 | |
766 |
|
765 | |||
767 | return self.dataOut.data #retorno necesario?? |
|
766 | return self.dataOut.data #retorno necesario?? | |
768 |
|
767 | |||
769 |
|
768 |
@@ -32,6 +32,7 class SpectraProc(ProcessingUnit): | |||||
32 | self.firstdatatime = None |
|
32 | self.firstdatatime = None | |
33 | self.profIndex = 0 |
|
33 | self.profIndex = 0 | |
34 | self.dataOut = Spectra() |
|
34 | self.dataOut = Spectra() | |
|
35 | self.dataOut.error=False | |||
35 | self.id_min = None |
|
36 | self.id_min = None | |
36 | self.id_max = None |
|
37 | self.id_max = None | |
37 | self.setupReq = False #Agregar a todas las unidades de proc |
|
38 | self.setupReq = False #Agregar a todas las unidades de proc | |
@@ -135,16 +136,17 class SpectraProc(ProcessingUnit): | |||||
135 | self.dataOut.flagShiftFFT = False |
|
136 | self.dataOut.flagShiftFFT = False | |
136 |
|
137 | |||
137 | def run(self, nProfiles=None, nFFTPoints=None, pairsList=None, ippFactor=None, shift_fft=False, |
|
138 | def run(self, nProfiles=None, nFFTPoints=None, pairsList=None, ippFactor=None, shift_fft=False, | |
138 |
zeroPad=False, zeroPoints=0, runNextUnit |
|
139 | zeroPad=False, zeroPoints=0, runNextUnit=0): | |
139 |
|
||||
140 | self.dataIn.runNextUnit = runNextUnit |
|
140 | self.dataIn.runNextUnit = runNextUnit | |
141 | try: |
|
141 | try: | |
142 | type = self.dataIn.type.decode("utf-8") |
|
142 | type = self.dataIn.type.decode("utf-8") | |
143 | self.dataIn.type = type |
|
143 | self.dataIn.type = type | |
144 | except: |
|
144 | except Exception as e: | |
|
145 | # print("spc -> ",e) | |||
145 | pass |
|
146 | pass | |
146 |
|
147 | |||
147 | if self.dataIn.type == "Spectra": |
|
148 | if self.dataIn.type == "Spectra": | |
|
149 | #print("AQUI") | |||
148 | try: |
|
150 | try: | |
149 | self.dataOut.copy(self.dataIn) |
|
151 | self.dataOut.copy(self.dataIn) | |
150 | self.dataOut.radarControllerHeaderObj = self.dataIn.radarControllerHeaderObj.copy() |
|
152 | self.dataOut.radarControllerHeaderObj = self.dataIn.radarControllerHeaderObj.copy() | |
@@ -301,7 +303,7 class SpectraProc(ProcessingUnit): | |||||
301 | else: |
|
303 | else: | |
302 | raise ValueError("The type of input object '%s' is not valid".format( |
|
304 | raise ValueError("The type of input object '%s' is not valid".format( | |
303 | self.dataIn.type)) |
|
305 | self.dataIn.type)) | |
304 |
|
306 | # print("SPC done") | ||
305 |
|
307 | |||
306 | def __selectPairs(self, pairsList): |
|
308 | def __selectPairs(self, pairsList): | |
307 |
|
309 |
General Comments 0
You need to be logged in to leave comments.
Login now