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

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

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)
getJobsSites(jobIDs)
getJobsStates(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 JobDB

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

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