schain-jc Commit - r1189:67ce1e63c533

15

import h5py

15

import h5py

16

17

from schainpy.model.io.jroIO_base import JRODataReader

17

from schainpy.model.io.jroIO_base import JRODataReader

18

from schainpy.model.proc.jroproc_base import ProcessingUnit, Operation

18

from schainpy.model.proc.jroproc_base import ProcessingUnit, Operation, MPDecorator

19

from schainpy.model.data.jrodata import Parameters

19

from schainpy.model.data.jrodata import Parameters

20

from schainpy.utils import log

20

from schainpy.utils import log

21

70

71

return iterable

71

return iterable

72

73

@MPDecorator

74

class MADReader(JRODataReader, ProcessingUnit):

74

class MADReader(JRODataReader, ProcessingUnit):

75

76

def __init__(self, **~~kwargs~~):

76

def __init__(self):

77

78

ProcessingUnit.__init__(self, **~~kwargs~~)

78

ProcessingUnit.__init__(self)

79

80

self.dataOut = Parameters()

80

self.dataOut = Parameters()

81

self.counter_records = 0

81

self.counter_records = 0

495

self.ext)

495

self.ext)

496

497

self.fullname = os.path.join(self.path, filename)

497

self.fullname = os.path.join(self.path, filename)

498

499

if os.path.isfile(self.fullname) :

499

if os.path.isfile(self.fullname) :

500

log.warning(

500

log.warning(

501

'Destination file {} already exists, previous file deleted.'.format(

501

'Destination file {} already exists, previous file deleted.'.format(

554

attr, x = value

554

attr, x = value

555

data = getattr(self.dataOut, attr)

555

data = getattr(self.dataOut, attr)

556

out[key] = data[int(x)]

556

out[key] = data[int(x)]

557

558

a = numpy.array([out[k] for k in self.keys])

558

a = numpy.array([out[k] for k in self.keys])

559

nrows = numpy.array([numpy.isnan(a[:, x]).all() for x in range(len(heights))])

559

nrows = numpy.array([numpy.isnan(a[:, x]).all() for x in range(len(heights))])

560

index = numpy.where(nrows == False)[0]

560

index = numpy.where(nrows == False)[0]

	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

             import h5py
             from schainpy.model.io.jroIO_base import JRODataReader
-            from schainpy.model.proc.jroproc_base import ProcessingUnit, Operation
+            from schainpy.model.proc.jroproc_base import ProcessingUnit, Operation, MPDecorator
             from schainpy.model.data.jrodata import Parameters
             from schainpy.utils import log
                 return iterable
+            @MPDecorator
             class MADReader(JRODataReader, ProcessingUnit):
-                def __init__(self, **kwargs):
+                def __init__(self):
-                    ProcessingUnit.__init__(self, **kwargs)
+                    ProcessingUnit.__init__(self)
                     self.dataOut = Parameters()
                     self.counter_records = 0
                                                self.ext)
                     self.fullname = os.path.join(self.path, filename)
                     if os.path.isfile(self.fullname) :
                         log.warning(
                             'Destination file {} already exists, previous file deleted.'.format(
                             attr, x = value
                             data = getattr(self.dataOut, attr)
                             out[key] = data[int(x)]
                     a = numpy.array([out[k] for k in self.keys])
                     nrows = numpy.array([numpy.isnan(a[:, x]).all() for x in range(len(heights))])
                     index = numpy.where(nrows == False)[0]