JobMonitoringHandler

JobMonitoringHandler is the implementation of the JobMonitoring service in the DISET framework

The following methods are available in the Service interface

class DIRAC.WorkloadManagementSystem.Service.JobMonitoringHandler.JobMonitoringHandler(handlerInitDict, trid)

Bases: DIRAC.Core.DISET.RequestHandler.RequestHandler

exception ConnectionError(msg)

Bases: exceptions.Exception

__init__(msg)

x.__init__(…) initializes x; see help(type(x)) for signature

args
message
__init__(handlerInitDict, trid)

Constructor

Parameters:
  • handlerInitDict (dictionary) – Information vars for the service
  • trid (object) – Transport to use
auth_ping = ['all']
static export_echo(data)

This method used for testing the performance of a service

static export_getApplicationStates()

Return Distinct Values of ApplicationStatus job Attribute in WMS

static export_getAtticJobParameters(jobID, parameters=None, rescheduleCycle=-1)
static export_getCounters(attrList, attrDict=None, cutDate='')

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

static export_getCurrentJobCounters(attrDict=None)

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

static export_getInputData(jobID)

Get input data for the specified jobs

static export_getJobAttribute(jobID, attribute)
static export_getJobAttributes(jobID)
static export_getJobGroups(condDict=None, cutDate=None)

Return Distinct Values of ProductionId job Attribute in WMS

static export_getJobHeartBeatData(jobID)
static export_getJobJDL(jobID, original)
static export_getJobLoggingInfo(jobID)
static export_getJobOwner(jobID)
export_getJobPageSummaryWeb(selectDict, sortList, startItem, maxItems, selectJobs=True)

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

static export_getJobParameter(jobID, parName)
Parameters:
  • jobID (str/int/long) – one single Job ID
  • parName (str) – one single parameter name
static export_getJobParameters(jobIDs, parName=None)
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)
static export_getJobPrimarySummary(jobID)
static export_getJobSite(jobID)
static export_getJobStats(attribute, selectDict)

Get job statistics distribution per attribute value with a given selection

static export_getJobStatus(jobID)
static export_getJobSummary(jobID)
static export_getJobTypes()

Return Distinct Values of JobType job Attribute in WMS

static export_getJobs(attrDict=None, cutDate=None)

Return list of JobIds matching the condition given in attrDict

static export_getJobsApplicationStatus(jobIDs)
static export_getJobsMinorStatus(jobIDs)
static export_getJobsParameters(*args, **kwargs)
static export_getJobsPrimarySummary(jobIDs)
static export_getJobsSites(jobIDs)
static export_getJobsStatus(jobIDs)
static export_getJobsSummary(jobIDs)
static export_getMinorStates()

Return Distinct Values of Minor Status job Attribute in WMS

static export_getOwnerGroup()

Return Distinct Values of OwnerGroup from the JobsDB

static export_getOwners()

Return Distinct Values of Owner job Attribute in WMS

static export_getProductionIds()

Return Distinct Values of ProductionId job Attribute in WMS

static export_getSiteSummary()
static export_getSites()

Return Distinct Values of Site job Attribute in WMS

static export_getStates()

Return Distinct Values of Status job Attribute in WMS

export_ping()
static export_traceJobParameter(site, localID, parameter, date, until)
static export_traceJobParameters(site, localID, parameterList, attributeList, date, until)
classmethod getCSOption(optionName, defaultValue=False)

Get an option from the CS section of the services

Returns:Value for serviceSection/optionName in the CS being defaultValue the default
getRemoteAddress()

Get the address of the remote peer.

Returns:Address of remote peer.
getRemoteCredentials()

Get the credentials of the remote peer.

Returns:Credentials dictionary of remote peer.
initialize()

Initialize this instance of the handler (to be overwritten)

srv_disconnect(trid=None)
classmethod srv_disconnectClient(trid)
srv_getActionTuple()
classmethod srv_getCSOption(optionName, defaultValue=False)

Get an option from the CS section of the services

Returns:Value for serviceSection/optionName in the CS being defaultValue the default
srv_getClientSetup()
srv_getClientVO()
srv_getFormattedRemoteCredentials()
classmethod srv_getMonitor()
srv_getRemoteAddress()

Get the address of the remote peer.

Returns:Address of remote peer.
srv_getRemoteCredentials()

Get the credentials of the remote peer.

Returns:Credentials dictionary of remote peer.
classmethod srv_getServiceName()
srv_getTransportID()
classmethod srv_getURL()
classmethod srv_msgCreate(msgName)
srv_msgReply(msgObj)
classmethod srv_msgSend(trid, msgObj)
transfer_bulkFromClient(bulkId, token, bulkSize, fileHelper)
transfer_bulkToClient(bulkId, token, fileHelper)
transfer_fromClient(fileId, token, fileSize, fileHelper)
transfer_listBulk(bulkId, token, fileHelper)
transfer_toClient(fileId, token, fileHelper)
types_echo = [<type 'basestring'>]
types_getApplicationStates = []
types_getAtticJobParameters = [[<type 'int'>, <type 'long'>]]
types_getCounters = [<type 'list'>]
types_getCurrentJobCounters = []
types_getInputData = [[<type 'int'>, <type 'long'>]]
types_getJobAttribute = [<type 'int'>, <type 'basestring'>]
types_getJobAttributes = [<type 'int'>]
types_getJobGroups = []
types_getJobHeartBeatData = [<type 'int'>]
types_getJobJDL = [<type 'int'>, <type 'bool'>]
types_getJobLoggingInfo = [<type 'int'>]
types_getJobOwner = [<type 'int'>]
types_getJobPageSummaryWeb = [<type 'dict'>, <type 'list'>, <type 'int'>, <type 'int'>]
types_getJobParameter = [[<type 'basestring'>, <type 'int'>, <type 'long'>], <type 'basestring'>]
types_getJobParameters = [[<type 'basestring'>, <type 'int'>, <type 'long'>, <type 'list'>]]
types_getJobPrimarySummary = [<type 'int'>]
types_getJobSite = [<type 'int'>]
types_getJobStats = [<type 'basestring'>, <type 'dict'>]
types_getJobStatus = [<type 'int'>]
types_getJobSummary = [<type 'int'>]
types_getJobTypes = []
types_getJobs = []
types_getJobsApplicationStatus = [<type 'list'>]
types_getJobsMinorStatus = [<type 'list'>]
types_getJobsParameters = [<type 'list'>, <type 'list'>]
types_getJobsPrimarySummary = [<type 'list'>]
types_getJobsSites = [<type 'list'>]
types_getJobsStatus = [<type 'list'>]
types_getJobsSummary = [<type 'list'>]
types_getMinorStates = []
types_getOwnerGroup = []
types_getOwners = []
types_getProductionIds = []
types_getSiteSummary = []
types_getSites = []
types_getStates = []
types_ping = []
types_traceJobParameter = [<type 'basestring'>, [<type 'basestring'>, <type 'int'>, <type 'long'>, <type 'list'>], <type 'basestring'>, [<type 'basestring'>, None], [<type 'basestring'>, None]]
types_traceJobParameters = [<type 'basestring'>, [<type 'basestring'>, <type 'int'>, <type 'long'>, <type 'list'>], [<type 'list'>, None], [<type 'list'>, None], [<type 'basestring'>, None], [<type 'basestring'>, None]]
DIRAC.WorkloadManagementSystem.Service.JobMonitoringHandler.initializeJobMonitoringHandler(serviceInfo)