Package Ganga :: Package Lib :: Package Condor :: Module Condor' :: Class Condor
[hide private]
[frames] | no frames]

Class Condor

source code

                 object --+            
                          |            
   GPIDev.Base.Objects.Node --+        
                              |        
GPIDev.Base.Objects.GangaObject --+    
                                  |    
  GPIDev.Adapters.IBackend.IBackend --+
                                      |
                                     Condor

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

Nested Classes [hide private]
  _proxyClass
Condor backend - submit jobs to a Condor pool.

Inherited from GPIDev.Base.Objects.GangaObject: __metaclass__

Instance Methods [hide private]
 
__init__(self)
x.__init__(...) initializes x; see help(type(x)) for signature
source code
 
kill(self)
Kill running job.
source code
 
preparejob(self, jobconfig, master_input_sandbox)
Prepare Condor description file
source code
 
resubmit(self)
Resubmit job that has already been configured.
source code
 
submit(self, jobconfig, master_input_sandbox)
Submit job to backend.
source code
 
submit_cdf(self, cdfpath='')
Submit Condor Description File.
source code

Inherited from GPIDev.Adapters.IBackend.IBackend: check_auto_resubmit, getStateTime, master_auto_resubmit, master_kill, master_prepare, master_resubmit, master_submit, peek, remove, setup, timedetails

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

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

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

Class Methods [hide private]
Static Methods [hide private]
 
updateMonitoringInformation(jobs)
Update monitoring information for individual jobs: jobs is a list which may contain subjobs as well as the non-split jobs.
source code

Inherited from GPIDev.Adapters.IBackend.IBackend: master_updateMonitoringInformation

Class Variables [hide private]
  _name = 'Condor'
  _schema = <Ganga.GPIDev.Schema.Schema.Schema instance at 0x337...
  actualCE = <Ganga.GPIDev.Base.Objects.Descriptor object at 0x3...
  cputime = <Ganga.GPIDev.Base.Objects.Descriptor object at 0x33...
  env = <Ganga.GPIDev.Base.Objects.Descriptor object at 0x3379810>
  getenv = <Ganga.GPIDev.Base.Objects.Descriptor object at 0x337...
  globus_rsl = <Ganga.GPIDev.Base.Objects.Descriptor object at 0...
  globusscheduler = <Ganga.GPIDev.Base.Objects.Descriptor object...
  id = <Ganga.GPIDev.Base.Objects.Descriptor object at 0x3379590>
  rank = <Ganga.GPIDev.Base.Objects.Descriptor object at 0x3379490>
  requirements = <Ganga.GPIDev.Base.Objects.Descriptor object at...
  shared_filesystem = <Ganga.GPIDev.Base.Objects.Descriptor obje...
  status = <Ganga.GPIDev.Base.Objects.Descriptor object at 0x337...
  statusDict = {'0': 'Unexpanded', '1': 'Idle', '2': 'Running', ...
  submit_options = <Ganga.GPIDev.Base.Objects.Descriptor object ...
  universe = <Ganga.GPIDev.Base.Objects.Descriptor object at 0x3...

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

Properties [hide private]

Inherited from object: __class__

Method Details [hide private]

__init__(self)
(Constructor)

source code 

x.__init__(...) initializes x; see help(type(x)) for signature

Overrides: object.__init__
(inherited documentation)

kill(self)

source code 
Kill running job.

No arguments other than self

Return value: True if job killed successfully,
              or False otherwise

Overrides: GPIDev.Adapters.IBackend.IBackend.kill

resubmit(self)

source code 
Resubmit job that has already been configured.

Return value: True if job is resubmitted successfully,
              or False otherwise

Overrides: GPIDev.Adapters.IBackend.IBackend.resubmit

submit(self, jobconfig, master_input_sandbox)

source code 
Submit job to backend.
             
Return value: True if job is submitted successfully,
              or False otherwise

Overrides: GPIDev.Adapters.IBackend.IBackend.submit

submit_cdf(self, cdfpath='')

source code 
Submit Condor Description File.

Argument other than self:
   cdfpath - path to Condor Description File to be submitted
             
Return value: True if job is submitted successfully,
              or False otherwise

updateMonitoringInformation(jobs)
Static Method

source code 

Update monitoring information for individual jobs: jobs is a list which may contain subjobs as well as the non-split jobs. This method is never called by the framework directly. It may only be called by the default implementation of master_updateMonitoringInformation().

Overrides: GPIDev.Adapters.IBackend.IBackend.updateMonitoringInformation
(inherited documentation)

Class Variable Details [hide private]

_schema

Value:
<Ganga.GPIDev.Schema.Schema.Schema instance at 0x3370e18>

actualCE

Value:
<Ganga.GPIDev.Base.Objects.Descriptor object at 0x3379610>

cputime

Value:
<Ganga.GPIDev.Base.Objects.Descriptor object at 0x3379390>

getenv

Value:
<Ganga.GPIDev.Base.Objects.Descriptor object at 0x3379410>

globus_rsl

Value:
<Ganga.GPIDev.Base.Objects.Descriptor object at 0x3379310>

globusscheduler

Value:
<Ganga.GPIDev.Base.Objects.Descriptor object at 0x3379790>

requirements

Value:
<Ganga.GPIDev.Base.Objects.Descriptor object at 0x3379690>

shared_filesystem

Value:
<Ganga.GPIDev.Base.Objects.Descriptor object at 0x3379510>

status

Value:
<Ganga.GPIDev.Base.Objects.Descriptor object at 0x3379250>

statusDict

Value:
{'0': 'Unexpanded',
 '1': 'Idle',
 '2': 'Running',
 '3': 'Removed',
 '4': 'Completed',
 '5': 'Held'}

submit_options

Value:
<Ganga.GPIDev.Base.Objects.Descriptor object at 0x3379890>

universe

Value:
<Ganga.GPIDev.Base.Objects.Descriptor object at 0x3379710>