JobMonitoringClient

Class that contains client access to the job monitoring handler.

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

Bases: DIRAC.Core.Base.Client.Client

__init__(**kwargs)

C’tor.

Parameters:kwargs – just stored as an attribute and passed when creating the RPCClient
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
getApplicationStates(**kwargs)

Return Distinct Values of ApplicationStatus job Attribute in WMS

Automatically created for the service function export_getApplicationStates()

getAtticJobParameters(jobID, parameters, rescheduleCycle, **kwargs)

Automatically created for the service function export_getAtticJobParameters()

Parameters:
  • jobID – jobID
  • parameters – parameters
  • rescheduleCycle – rescheduleCycle
getCounters(attrList, attrDict, cutDate, **kwargs)

Retrieve list of distinct attributes values from attrList with attrDict as condition. For each set of distinct values, count number of occurences. Return a list. Each item is a list with 2 items, the list of distinct attribute values and the counter

Automatically created for the service function export_getCounters()

Parameters:
  • attrList – attrList
  • attrDict – attrDict
  • cutDate – cutDate
getCurrentJobCounters(attrDict, **kwargs)

Get job counters per Status with attrDict selection. Final statuses are given for the last day.

Automatically created for the service function export_getCurrentJobCounters()

Parameters:attrDict – attrDict
getInputData(jobID, **kwargs)

Get input data for the specified jobs

Automatically created for the service function export_getInputData()

Parameters:jobID – jobID
getJobAttribute(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(jobID, **kwargs)
Parameters:jobID (int) – one single Job ID

Automatically created for the service function export_getJobAttributes()

getJobGroups(condDict, cutDate, **kwargs)

Return Distinct Values of ProductionId job Attribute in WMS

Automatically created for the service function export_getJobGroups()

Parameters:
  • condDict – condDict
  • cutDate – cutDate
getJobHeartBeatData(jobID, **kwargs)

Automatically created for the service function export_getJobHeartBeatData()

Parameters:jobID – jobID
getJobJDL(jobID, original, **kwargs)

Automatically created for the service function export_getJobJDL()

Parameters:
  • jobID – jobID
  • original – original
getJobLoggingInfo(jobID, **kwargs)

Automatically created for the service function export_getJobLoggingInfo()

Parameters:jobID – jobID
getJobOptParameters(jobID, **kwargs)

Automatically created for the service function export_getJobOptParameters()

Parameters:jobID – jobID
getJobOwner(jobID, **kwargs)

Automatically created for the service function export_getJobOwner()

Parameters:jobID – jobID
getJobPageSummaryWeb(self, selectDict, sortList, startItem, maxItems, selectJobs, **kwargs)

Get the summary of the job information for a given page in the job monitor in a generic format

Automatically created for the service function export_getJobPageSummaryWeb()

Parameters:
  • selectDict – selectDict
  • sortList – sortList
  • startItem – startItem
  • maxItems – maxItems
  • selectJobs – selectJobs
getJobParameter(jobID, parName, **kwargs)
Parameters:
  • jobID (str/int/long) – one single Job ID
  • parName (str) – one single parameter name

Automatically created for the service function export_getJobParameter()

getJobParameters(jobIDs, parName, **kwargs)
Parameters:
  • jobIDs (str/int/long/list) – one single job ID or a list of them
  • parName (str) – one single parameter name, or None (meaning all of them)

Automatically created for the service function export_getJobParameters()

getJobPrimarySummary(jobID, **kwargs)

Automatically created for the service function export_getJobPrimarySummary()

Parameters:jobID – jobID
getJobSite(jobID, **kwargs)

Automatically created for the service function export_getJobSite()

Parameters:jobID – jobID
getJobStats(attribute, selectDict, **kwargs)

Get job statistics distribution per attribute value with a given selection

Automatically created for the service function export_getJobStats()

Parameters:
  • attribute – attribute
  • selectDict – selectDict
getJobStatus(jobID, **kwargs)

Automatically created for the service function export_getJobStatus()

Parameters:jobID – jobID
getJobSummary(jobID, **kwargs)

Automatically created for the service function export_getJobSummary()

Parameters:jobID – jobID
getJobTypes(**kwargs)

Return Distinct Values of JobType job Attribute in WMS

Automatically created for the service function export_getJobTypes()

getJobs(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, **kwargs)

Automatically created for the service function export_getJobsApplicationStatus()

Parameters:jobIDs – jobIDs
getJobsMinorStatus(jobIDs, **kwargs)

Automatically created for the service function export_getJobsMinorStatus()

Parameters:jobIDs – jobIDs
getJobsParameters(jobIDs, parameters, **kwargs)

Automatically created for the service function export_getJobsParameters()

Parameters:
  • jobIDs – jobIDs
  • parameters – parameters
getJobsPrimarySummary(jobIDs, **kwargs)

Automatically created for the service function export_getJobsPrimarySummary()

Parameters:jobIDs – jobIDs
getJobsSites(jobIDs, **kwargs)

Automatically created for the service function export_getJobsSites()

Parameters:jobIDs – jobIDs
getJobsStatus(jobIDs, **kwargs)

Automatically created for the service function export_getJobsStatus()

Parameters:jobIDs – jobIDs
getJobsSummary(jobIDs, **kwargs)

Automatically created for the service function export_getJobsSummary()

Parameters:jobIDs – jobIDs
getMinorStates(**kwargs)

Return Distinct Values of Minor Status job Attribute in WMS

Automatically created for the service function export_getMinorStates()

getOwnerGroup(**kwargs)

Return Distinct Values of OwnerGroup from the JobsDB

Automatically created for the service function export_getOwnerGroup()

getOwners(**kwargs)

Return Distinct Values of Owner job Attribute in WMS

Automatically created for the service function export_getOwners()

getProductionIds(**kwargs)

Return Distinct Values of ProductionId job Attribute in WMS

Automatically created for the service function export_getProductionIds()

getServer()

Getter for the server url. Useful ?

getSiteSummary(**kwargs)

Automatically created for the service function export_getSiteSummary()

getSites(**kwargs)

Return Distinct Values of Site job Attribute in WMS

Automatically created for the service function export_getSites()

getStates(**kwargs)

Return Distinct Values of Status job Attribute in WMS

Automatically created for the service function export_getStates()

setServer(url)

Set the server URL used by default

Parameters:url – url of the service
setTimeout(**kwargs)

Specify the timeout of the call. Forwarded to RPCClient

param int timeout:
 timeout for the RPC calls

Deprecated: Please use self._getRPC(timeout) or self.timeout=<value>

traceJobParameter(**kwargs)

Deprecated: Unused

traceJobParameters(**kwargs)

Deprecated: Unused