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

Class Remote

source code

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

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

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

Inherited from GPIDev.Base.Objects.GangaObject: __metaclass__

Instance Methods [hide private]
 
__del__(self) source code
 
__init__(self)
x.__init__(...) initializes x; see help(type(x)) for signature
source code
 
grabremoteinfo(self, out) source code
 
kill(self)
Kill running job.
source code
 
opentransport(self) source code
 
preparejob(self, jobconfig, master_input_sandbox)
Prepare the script to create the job on the remote host
source code
 
remove(self)
Remove the selected job from the remote site
source code
 
resubmit(self)
Resubmit the job.
source code
 
run_remote_script(self, script_name, pre_script)
Run a ganga script on the remote site
source code
 
setup(self)
This is a hook called for each job when Ganga.Core services are started up.
source code
 
submit(self, jobconfig, master_input_sandbox)
Submit the job to the remote backend.
source code

Inherited from GPIDev.Adapters.IBackend.IBackend: check_auto_resubmit, getStateTime, master_auto_resubmit, master_kill, master_prepare, master_resubmit, master_submit, peek, 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]
  _code = 'ZNTRCV'
  _key = {}
  _name = 'Remote'
  _port = 22
  _schema = <Ganga.GPIDev.Schema.Schema.Schema instance at 0x36e...
  _sftp = None
hash(x)
  _transport = None
hash(x)
  _transportarray = None
hash(x)
  actualCE = <Ganga.GPIDev.Base.Objects.Descriptor object at 0x3...
  environment = <Ganga.GPIDev.Base.Objects.Descriptor object at ...
  exitcode = <Ganga.GPIDev.Base.Objects.Descriptor object at 0x3...
  ganga_cmd = <Ganga.GPIDev.Base.Objects.Descriptor object at 0x...
  ganga_dir = <Ganga.GPIDev.Base.Objects.Descriptor object at 0x...
  host = <Ganga.GPIDev.Base.Objects.Descriptor object at 0x377c910>
  key_type = <Ganga.GPIDev.Base.Objects.Descriptor object at 0x3...
  pre_script = <Ganga.GPIDev.Base.Objects.Descriptor object at 0...
  remote_backend = <Ganga.GPIDev.Base.Objects.Descriptor object ...
  remote_job_id = <Ganga.GPIDev.Base.Objects.Descriptor object a...
  ssh_key = <Ganga.GPIDev.Base.Objects.Descriptor object at 0x37...
  username = <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

remove(self)

source code 
Remove the selected job from the remote site

No arguments other than self

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

Overrides: GPIDev.Adapters.IBackend.IBackend.remove

resubmit(self)

source code 
Resubmit the job.

No arguments other than self

Return value: 1 if job was resubmitted,
              or 0 otherwise

Overrides: GPIDev.Adapters.IBackend.IBackend.resubmit

setup(self)

source code 

This is a hook called for each job when Ganga.Core services are started up. The hook is called before the monitoring subsystem is enabled. This hook may be used by some backends to do specialized setup (e.g. to open ssh transport pipes of the Remote backend)

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

submit(self, jobconfig, master_input_sandbox)

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

Overrides: GPIDev.Adapters.IBackend.IBackend.submit

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 0x36e07e8>

actualCE

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

environment

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

exitcode

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

ganga_cmd

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

ganga_dir

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

key_type

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

pre_script

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

remote_backend

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

remote_job_id

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

ssh_key

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

username

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