Package Ganga :: Package Lib :: Package Mergers :: Module Merger :: Class SmartMerger

Class SmartMerger

                 object --+            
                          |            
   GPIDev.Base.Objects.Node --+        
                              |        
GPIDev.Base.Objects.GangaObject --+    
                                  |    
    GPIDev.Adapters.IMerger.IMerger --+
                                      |
                                     SmartMerger

This is a Ganga.GPI.SmartMerger implementation class. Refer to Ganga.GPI.SmartMerger.__doc__ for documentation.

Nested Classes

[hide private]

_proxyClass
Allows the different types of merge to be run according to file extension in an automatic way.

Inherited from GPIDev.Base.Objects.GangaObject: __metaclass__

Instance Methods

[hide private]

merge(self, jobs, outputdir=None, ignorefailed=None, overwrite=None)
Merge the output of subjobs into the sum_outputdir.

source code

Inherited from GPIDev.Adapters.IMerger.IMerger: validatedMerge

Inherited from GPIDev.Base.Objects.GangaObject: __construct__, __deepcopy__, __getstate__, __init__, __setstate__, _attribute_filter__set__, _auto__init__, accept, getJobObject

Inherited from GPIDev.Base.Objects.GangaObject (private): _getReadAccess, _getRegistry, _getRegistryID, _getWriteAccess, _readonly, _releaseWriteAccess, _setDirty, _setFlushed, _setRegistry

Inherited from GPIDev.Base.Objects.Node: __copy__, __eq__, __ne__, clone, copyFrom, printSummaryTree, printTree

Inherited from GPIDev.Base.Objects.Node (private): _getParent, _getRoot, _setParent

Inherited from object: __delattr__, __format__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __sizeof__, __str__, __subclasshook__

Class Methods

[hide private]

Inherited from GPIDev.Base.Objects.GangaObject (private): _declared_property

Class Variables

[hide private]

_category = 'mergers'

_exportmethods = ['merge']

_name = 'SmartMerger'

_schema = Schema(Version(1, 0), {'files': SimpleItem(defvalue=...

files = <Ganga.GPIDev.Base.Objects.Descriptor object at 0x17f7...

ignorefailed = <Ganga.GPIDev.Base.Objects.Descriptor object at...

overwrite = <Ganga.GPIDev.Base.Objects.Descriptor object at 0x...

Inherited from GPIDev.Adapters.IMerger.IMerger: set_outputdir_for_automerge

Inherited from GPIDev.Adapters.IMerger.IMerger (private): _hidden

Inherited from GPIDev.Base.Objects.GangaObject (private): _registry

Inherited from GPIDev.Base.Objects.Node (private): _index_cache, _parent

Properties

[hide private]

Inherited from object: __class__

Method Details

[hide private]

merge(self, jobs, outputdir=None, ignorefailed=None, overwrite=None)

source code

Merge the output of subjobs into the sum_outputdir. The options (keyword arguments) are merger-implementation specific and should be defined in the derived classes.

Overrides: GPIDev.Adapters.IMerger.IMerger.merge: (inherited documentation)

Class Variable Details

[hide private]

_schema

Value:

Schema(Version(1, 0), {'files': SimpleItem(defvalue= [], typelist= ['s
tr'], sequence= 1, doc= 'A list of files to merge.'), 'ignorefailed': 
SimpleItem(defvalue= False, doc= 'Jobs that are in the failed or kille
d states will be excluded from the merge when this flag is set to True
.'), 'overwrite': SimpleItem(defvalue= False, doc= 'The default behavi
our for this Merger object. Will overwrite output files.')})

files

Value:

<Ganga.GPIDev.Base.Objects.Descriptor object at 0x17f7f90>

ignorefailed

Value:

<Ganga.GPIDev.Base.Objects.Descriptor object at 0x17fe090>

overwrite

Value:

<Ganga.GPIDev.Base.Objects.Descriptor object at 0x17fe110>