schain-jc Commit - r1181:eb60268405c6

Multiprocessing for BLTR (sswma) data

Juan C. Espinoza -

r1181:eb60268405c6

parent child

Context file:

r1181:eb60268405c6

Collapse all files

schainpy/model/io/bltrIO_param.py +4 -6

             import numpy
-            from schainpy.model.proc.jroproc_base import ProcessingUnit
+            from schainpy.model.proc.jroproc_base import ProcessingUnit, MPDecorator
             from schainpy.model.data.jrodata import Parameters
             from schainpy.model.io.jroIO_base import JRODataReader, isNumber
             from schainpy.utils import log
                 ('sea_algorithm', '<u4')
             ])
+            @MPDecorator
             class BLTRParamReader(JRODataReader, ProcessingUnit):
                 '''
                 Boundary Layer and Tropospheric Radar (BLTR) reader, Wind velocities and SNR from *.sswma files
                     file_id = self.fileIndex
                     if file_id == len(self.fileList):
-                        log.success('No more files in the folder', 'BLTRParamReader')
                         self.flagNoMoreFiles = 1
                         return 0
                     pointer = self.fp.tell()
                     header_rec = numpy.fromfile(self.fp, REC_HEADER_STRUCTURE, 1)
-                    self.nchannels = header_rec['nchan'][0] / 2
+                    self.nchannels = int(header_rec['nchan'][0] / 2)
                     self.kchan = header_rec['nrxs'][0]
                     self.nmodes = header_rec['nmodes'][0]
                     self.nranges = header_rec['nranges'][0]
                     '''
                     if self.flagNoMoreFiles:
                         self.dataOut.flagNoData = True
-                        log.success('No file left to process', 'BLTRParamReader')
+                        self.dataOut.error = (1, 'No More files to read')
-                        return 0
                     if not self.readNextBlock():
                         self.dataOut.flagNoData = True

schainpy/model/proc/bltrproc_parameters.py +4 -5

             from numpy import transpose
-            from .jroproc_base import ProcessingUnit, Operation
+            from schainpy.model.proc.jroproc_base import ProcessingUnit, Operation, MPDecorator
             from schainpy.model.data.jrodata import Parameters
+            @MPDecorator
             class BLTRParametersProc(ProcessingUnit):
                 '''
                 Processing unit for BLTR parameters data (winds)
                     self.dataOut.year - Experiment year
                 '''
-                def __init__(self, **kwargs):
+                def __init__(self):
                     '''
                     Inputs: None
                     '''
-                    ProcessingUnit.__init__(self, **kwargs)
+                    ProcessingUnit.__init__(self)
                     self.dataOut = Parameters()
-                    self.isConfig = False
                 def setup(self, mode):
                     '''

General Comments 0

Write
Preview

You need to be logged in to leave comments. Login now

No TODOs yet

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages