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

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(cls, condDict, older, newer, **kwargs)

Return Distinct Values of ApplicationStatus job Attribute in WMS

Automatically created for the service function export_getApplicationStates()

Parameters

• condDict – condDict

• older – older

• newer – newer

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

Automatically created for the service function export_getAtticJobParameters()

Parameters

• jobID – jobID

• parameters – parameters

• rescheduleCycle – rescheduleCycle

getClientKWArgs()

Returns a copy of the connection arguments

getCounters(cls, 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(cls, 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(cls, jobID, **kwargs)

Get input data for the specified jobs

Automatically created for the service function export_getInputData()

Parameters

jobID – jobID

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()

getJobGroups(cls, condDict, older, cutDate, **kwargs)

Return Distinct Values of ProductionId job Attribute in WMS

Automatically created for the service function export_getJobGroups()

Parameters

• condDict – condDict

• older – older

• cutDate – cutDate

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

getJobOptParameters(cls, jobID, **kwargs)

Automatically created for the service function export_getJobOptParameters()

Parameters

jobID – jobID

getJobOwner(cls, 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(cls, 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)

getJobPrimarySummary(cls, jobID, **kwargs)

Automatically created for the service function export_getJobPrimarySummary()

Parameters

jobID – jobID

getJobSite(cls, jobID, **kwargs)

Automatically created for the service function export_getJobSite()

Parameters

jobID – jobID

getJobStats(cls, 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(cls, jobID, **kwargs)

Automatically created for the service function export_getJobStatus()

Parameters

jobID – jobID

getJobSummary(cls, jobID, **kwargs)

Automatically created for the service function export_getJobSummary()

Parameters

jobID – jobID

getJobTypes(cls, condDict, older, newer, **kwargs)

Return Distinct Values of JobType job Attribute in WMS

Automatically created for the service function export_getJobTypes()

Parameters

• condDict – condDict

• older – older

• newer – newer

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)

getJobsParameters(jobIDs, parameters)

getJobsPrimarySummary(jobIDs)

getJobsSites(jobIDs)

getJobsStatus(jobIDs)

getJobsSummary(cls, jobIDs, **kwargs)

Automatically created for the service function export_getJobsSummary()

Parameters

jobIDs – jobIDs

getMinorStates(cls, condDict, older, newer, **kwargs)

Return Distinct Values of Minor Status job Attribute in WMS

Automatically created for the service function export_getMinorStates()

Parameters

• condDict – condDict

• older – older

• newer – newer

getOwnerGroup(cls, **kwargs)

Return Distinct Values of OwnerGroup from the JobsDB

Automatically created for the service function export_getOwnerGroup()

getOwners(cls, condDict, older, newer, **kwargs)

Return Distinct Values of Owner job Attribute in WMS

Automatically created for the service function export_getOwners()

Parameters

• condDict – condDict

• older – older

• newer – newer

getProductionIds(cls, condDict, older, newer, **kwargs)

Return Distinct Values of ProductionId job Attribute in WMS

Automatically created for the service function export_getProductionIds()

Parameters

• condDict – condDict

• older – older

• newer – newer

getServer()

Getter for the server url. Useful ?

getSiteSummary(cls, **kwargs)

Automatically created for the service function export_getSiteSummary()

getSites(cls, condDict, older, newer, **kwargs)

Return Distinct Values of Site job Attribute in WMS

Automatically created for the service function export_getSites()

Parameters

• condDict – condDict

• older – older

• newer – newer

getStates(cls, condDict, older, newer, **kwargs)

Return Distinct Values of Status job Attribute in WMS

Automatically created for the service function export_getStates()

Parameters

• condDict – condDict

• older – older

• newer – newer

httpsClient

alias of TornadoClient

setServer(url)

Set the server URL used by default

Parameters

url – url of the service

traceJobParameter(cls, site, localID, parameter, date, until, **kwargs)

Automatically created for the service function export_traceJobParameter()

Parameters

• site – site

• localID – localID

• parameter – parameter

• date – date

• until – until

traceJobParameters(cls, site, localID, parameterList, attributeList, date, until, **kwargs)

Automatically created for the service function export_traceJobParameters()

Parameters

• site – site

• localID – localID

• parameterList – parameterList

• attributeList – attributeList

• date – date

• until – until