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

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 DIRAC.Core.Tornado.Client.TornadoClient.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