Package Ganga :: Package Lib :: Package MonitoringServices :: Package ARDADashboard :: Package LCG :: Module ARDADashboardLCG :: Class ARDADashboardLCG
[hide private]
[frames] | no frames]

Class ARDADashboardLCG

source code

GPIDev.Adapters.IMonitoringService.IMonitoringService --+
                                                        |
                                                       ARDADashboardLCG

Instance Methods [hide private]
 
__init__(self, job_info)
Initialize the monitoring service.
source code
 
getJobInfo(self)
Return a static info object which static information about the job at submission time.
source code
 
getSandboxModules(self)
Get the list of module dependencies of this monitoring module.
source code
 
submit(self, **opts)
Submission of a job.
source code
 
start(self, **opts)
Application is about to start on the worker node.
source code
 
progress(self, **opts)
Application execution is in progress (called periodically, several times a second).
source code
 
stop(self, exitcode, **opts)
Application execution finished.
source code

Inherited from GPIDev.Adapters.IMonitoringService.IMonitoringService: complete, event, fail, getWrapperScriptConstructorText, kill, prepare, rollback, submitting

Static Methods [hide private]

Inherited from GPIDev.Adapters.IMonitoringService.IMonitoringService: getConfig

Class Variables [hide private]
  gridJobId = None
hash(x)
  gangaJobId = None
hash(x)
  gangaTaskId = None
hash(x)
  dashboard = None
hash(x)
  gridBackend = None
hash(x)
  gridCertificate = None
hash(x)
  VO = None
hash(x)
  taskPrefix = 'ganga'
  _complete = False
  _logger = None
hash(x)
Method Details [hide private]

__init__(self, job_info)
(Constructor)

source code 

Initialize the monitoring service.

If the monitoring service is created in the Ganga client then job_info is the original job object, and config_info is the original config object returned by getConfig().

If the monitoring service is created on the worker node then job_info is the return value of getJobInfo(), and config_info is the return value of getConfig().getEffectiveOptions(), i.e. a dictionary.

In order to support existing monitoring classes, which do not use config_info, if getConfig() returns None, the constructor is called with only the job_info argument.

Overrides: GPIDev.Adapters.IMonitoringService.IMonitoringService.__init__
(inherited documentation)

getJobInfo(self)

source code 

Return a static info object which static information about the job at submission time. Called by: ganga client.

The info object is passed to the contructor. Info object may only contain the standard python types (such as lists, dictionaries, int, strings).

Overrides: GPIDev.Adapters.IMonitoringService.IMonitoringService.getJobInfo
(inherited documentation)

getSandboxModules(self)

source code 
Get the list of module dependencies of this monitoring module.
Called by: ganga client.

Returns a list of modules which are imported by this module and
therefore must be shipped automatically to the worker node. The list
should include the module where this class is defined plus all modules
which represent the parent packages. The module containing the
IMonitoringService class is added automatically by the call to the
base class sandBoxModule() method. An example for a class defined in
the module Ganga/Lib/MonitoringServices/DummyMS/DummyMS.py which does
not have any further dependencies:

import Ganga.Lib.MonitoringServices.DummyMS
return IMonitoringService.getSandboxModules(self) + [
         Ganga,
         Ganga.Lib,
         Ganga.Lib.MonitoringServices,
         Ganga.Lib.MonitoringServices.DummyMS,
         Ganga.Lib.MonitoringServices.DummyMS.DummyMS
        ]
Note, that it should be possible to import all parent modules without side effects (so without importing automatically their other children).

Overrides: GPIDev.Adapters.IMonitoringService.IMonitoringService.getSandboxModules
(inherited documentation)

submit(self, **opts)

source code 

Submission of a job. Called by: ganga client.

Overrides: GPIDev.Adapters.IMonitoringService.IMonitoringService.submit
(inherited documentation)

start(self, **opts)

source code 

Application is about to start on the worker node. Called by: job wrapper.

Overrides: GPIDev.Adapters.IMonitoringService.IMonitoringService.start
(inherited documentation)

progress(self, **opts)

source code 

Application execution is in progress (called periodically, several times a second). Called by: job wrapper.

Overrides: GPIDev.Adapters.IMonitoringService.IMonitoringService.progress
(inherited documentation)

stop(self, exitcode, **opts)

source code 

Application execution finished. Called by: job wrapper.

Overrides: GPIDev.Adapters.IMonitoringService.IMonitoringService.stop
(inherited documentation)