Package arcjobtool :: Module ArcUtils :: Class ArcClient
[hide private]
[frames] | no frames]

Class ArcClient

source code


Instance Methods [hide private]
 
__init__(self, userConfig=None, logStream=None)
ArcClient class constructor
source code
 
enableServiceFiltering(self)
Enable rejected services list.
source code
 
disableServiceFiltering(self)
Disable rejected services list.
source code
 
logMsg(self, level, msg)
Logs a message to the ARC logger.
source code
 
logInfoMsg(self, msg)
Logs an info message to the ARC logger.
source code
 
logDebugMsg(self, msg)
Logs a debug message to the ARC logger.
source code
 
logErrorMsg(self, msg)
Logs an error message to the ARC logger.
source code
 
setLogStream(self, stream)
Assigns the logstream to instance.
source code
 
getLogStream(self)
Return current log stream.
source code
 
setDebugLevel(self, level)
Set debug level of the arc library.
source code
 
getDebugLevel(self)
Return the debug level of the arc library.
source code
 
setProxyFilename(self, filename)
Set proxy filename.
source code
 
getProxyFilename(self)
Return proxy filename
source code
 
saveConfiguration(self)
Save current configuration.
source code
 
__loadJobs(self)
Load job list from XML file.
source code
 
loadJobList(self)
Load job list from XML file.
source code
 
hasValidProxy(self)
Return status of proxy.
source code
 
findTargets(self)
Find possible targets by querying information system.
source code
 
loadBroker(self, brokerName='Random')
Wrapper function for encapsulating ARC1 loading of of a broker instance.
source code
 
filterTargets(self, job) source code
 
findBestTarget(self, job)
Return a filtered list of suitable targets based on the RandomBroker component.
source code
 
submit_old(self, job)
Submit job to grid.
source code
 
submit(self, job)
Submit job to grid.
source code
 
submitJobList(self, jobList)
Submit job list to grid.
source code
 
get(self, jobIds=[], status=['FINISHED', 'FAILED'], keep=False)
Download results from jobs.
source code
 
kill(self, jobIds=[], status=[], force=False)
Kill running jobs.
source code
 
clean(self, jobIds=[], status=[], force=False)
Clean running jobs.
source code
 
doProgress(self, message)
Call progress update callback if assigned otherwise ignore.
source code
 
updateStatus(self)
Query information system and populate the jobs property with additional job information.
source code
 
sortKeysBy(self, byField='')
Sort job dictionary by field specified by the byField parameter.
source code
 
printJobs(self)
Print list of jobs managed by this class.
source code
 
printStatus(self)
Print status of jobs.
source code
 
getBrokerName(self) source code
 
setBrokerName(self, brokerName) source code
 
setTimeout(self, timeout) source code
 
getTimeout(self) source code

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

Properties [hide private]
  debugLevel
Return the debug level of the arc library.
  proxyFilename
Return proxy filename
  logStream
Return current log stream.
  brokerName
  timeout

Inherited from object: __class__

Method Details [hide private]

__init__(self, userConfig=None, logStream=None)
(Constructor)

source code 

ArcClient class constructor

Initialises properties and variables, sets up logging and loads job list.

Overrides: object.__init__

submit_old(self, job)

source code 

Submit job to grid. Requires that a list of filtered targets exists.

submit(self, job)

source code 

Submit job to grid. Requires that a list of filtered targets exists.

submitJobList(self, jobList)

source code 

Submit job list to grid. Requires a

doProgress(self, message)

source code 

Call progress update callback if assigned otherwise ignore.

message - Message to pass to progress callback function.


Property Details [hide private]

debugLevel

Return the debug level of the arc library.

Get Method:
getDebugLevel(self) - Return the debug level of the arc library.
Set Method:
setDebugLevel(self, level) - Set debug level of the arc library.

proxyFilename

Return proxy filename

Get Method:
getProxyFilename(self) - Return proxy filename
Set Method:
setProxyFilename(self, filename) - Set proxy filename.

logStream

Return current log stream.

Get Method:
getLogStream(self) - Return current log stream.
Set Method:
setLogStream(self, stream) - Assigns the logstream to instance.

brokerName

Get Method:
getBrokerName(self)
Set Method:
setBrokerName(self, brokerName)

timeout

Get Method:
getTimeout(self)
Set Method:
setTimeout(self, timeout)