JobMonitoringClient

Class that contains client access to the job monitoring handler.

class DIRAC.WorkloadManagementSystem.Client.JobMonitoringClient.JobMonitoringClient(**kwargs)

Bases: Client

__init__(**kwargs)

C’tor.

Parameters:

kwargs – just stored as an attribute and passed when creating the RPCClient

property call

To be removed once we’re sure self.call has been removed

Type:

Deprecated

diracxClient = None
executeRPC(*parms, **kws)

This method extracts some parameters from kwargs that are used as parameter of the constructor or RPCClient. Unfortunately, only a few of all the available parameters of BaseClient are exposed.

Parameters:

  • rpc – if an RPC client is passed, use that one

  • timeout – we can change the timeout on a per call bases. Default is self.timeout

  • url – We can specify which url to use

getClientKWArgs()

Returns a copy of the connection arguments

getInputData(jobIDs)
getJobAttribute(cls, jobID, attribute, **kwargs)
Parameters:

  • jobID (int) – one single Job ID

  • attribute (str) – one single attribute name

Automatically created for the service function export_getJobAttribute()

getJobAttributes(cls, jobID, attrList, **kwargs)
Parameters:

  • jobID (int) – one single Job ID

  • attrList (list) – optional list of attributes

Automatically created for the service function export_getJobAttributes()

getJobHeartBeatData(cls, jobID, **kwargs)

Automatically created for the service function export_getJobHeartBeatData()

Parameters:

jobID – jobID

getJobJDL(cls, jobID, original, **kwargs)

Automatically created for the service function export_getJobJDL()

Parameters:

  • jobID – jobID

  • original – original

getJobLoggingInfo(cls, jobID, **kwargs)

Automatically created for the service function export_getJobLoggingInfo()

Parameters:

jobID – jobID

getJobParameter(self, jobID, parName, **kwargs)
Parameters:

  • jobID (str/int) – one single Job ID

  • parName (str) – one single parameter name

Automatically created for the service function export_getJobParameter()

getJobParameters(jobIDs, parName=None)
getJobSummary(cls, jobID, **kwargs)

Automatically created for the service function export_getJobSummary()

Parameters:

jobID – jobID

getJobs(cls, attrDict, cutDate, **kwargs)

Return list of JobIds matching the condition given in attrDict

Automatically created for the service function export_getJobs()

Parameters:

  • attrDict – attrDict

  • cutDate – cutDate

getJobsApplicationStatus(jobIDs)
getJobsMinorStatus(jobIDs)
getJobsSites(jobIDs)
getJobsStates(jobIDs)
getJobsStatus(jobIDs)
getJobsSummary(cls, jobIDs, **kwargs)

Automatically created for the service function export_getJobsSummary()

Parameters:

jobIDs – jobIDs

getServer()

Getter for the server url. Useful ?

httpsClient

alias of TornadoClient

setServer(url)

Set the server URL used by default

Parameters:

url – url of the service