Package Ganga :: Package Lib :: Package LCG :: Module Grid :: Class Grid
[hide private]
[frames] | no frames]

Class Grid

source code

object --+
         |
        Grid

Helper class to implement grid interaction

Instance Methods [hide private]
 
__init__(self, middleware='EDG')
x.__init__(...) initializes x; see help(type(x)) for signature
source code
 
__setattr__(self, attr, value)
x.__setattr__('name', value) <==> x.name = value
source code
 
__get_cmd_prefix_hack__(self, binary=False) source code
 
__set_submit_option__(self) source code
 
__resolve_gridcmd_log_path__(self, regxp_logfname, cmd_output) source code
 
__clean_gridcmd_log__(self, regxp_logfname, cmd_output) source code
 
__print_gridcmd_log__(self, regxp_logfname, cmd_output) source code
 
__get_proxy_voname__(self)
Check validity of proxy vo
source code
 
__get_lfc_host__(self)
Gets the LFC_HOST: from current shell or querying BDII on demand
source code
 
__get_default_lfc__(self)
Gets the default lfc host from lcg-infosites
source code
 
__resolve_no_matching_jobs__(self, cmd_output)
Parsing the glite-wms-job-status log to get the glite jobs which have been removed from the WMS
source code
 
check_proxy(self)
Check the proxy and prompt the user to refresh it
source code
 
list_match(self, jdlpath, ce=None)
Returns a list of computing elements can run the job
source code
 
submit(self, jdlpath, ce=None)
Submit a JDL file to LCG
source code
 
native_master_cancel(self, jobids)
Native bulk cancellation supported by GLITE middleware.
source code
 
status(self, jobids, is_collection=False)
Query the status of jobs on the grid
source code
 
get_loginfo(self, jobids, directory, verbosity=1)
Fetch the logging info of the given job and save the output in the job's outputdir
source code
 
get_output(self, jobid, directory, wms_proxy=False)
Retrieve the output of a job on the grid
source code
 
cancelMultiple(self, jobids)
Cancel multiple jobs in one LCG job cancellation call
source code
 
cancel(self, jobid)
Cancel a job
source code
 
__cream_parse_job_status__(self, log)
Parsing job status report from CREAM CE status query
source code
 
__cream_ui_check__(self)
checking if CREAM CE environment is set properly
source code
 
cream_check_delegated_proxy(self, ce)
Checking if the delegation id to given CE is still valid.
source code
 
cream_proxy_delegation(self, ce)
CREAM CE proxy delegation
source code
 
cream_submit(self, jdlpath, ce)
CREAM CE direct job submission
source code
 
cream_status(self, jobids)
CREAM CE job status query
source code
 
cream_purgeMultiple(self, jobids)
CREAM CE job purging
source code
 
cream_cancelMultiple(self, jobids)
CREAM CE job cancelling
source code
 
cream_get_output(self, osbURIList, directory)
CREAM CE job output retrieval
source code
 
__get_app_exitcode__(self, outputdir) source code

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

Static Methods [hide private]
 
expandjdl(items)
Expand jdl items
source code
Class Variables [hide private]
  _attributes = 'middleware', 'credential', 'config', 'active', ...
Properties [hide private]

Inherited from object: __class__

Method Details [hide private]

__init__(self, middleware='EDG')
(Constructor)

source code 

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

Overrides: object.__init__
(inherited documentation)

__setattr__(self, attr, value)

source code 

x.__setattr__('name', value) <==> x.name = value

Overrides: object.__setattr__
(inherited documentation)

Class Variable Details [hide private]

_attributes

Value:
'middleware', 'credential', 'config', 'active', 'perusable'