JobManagerHandler

JobManagerHandler is the implementation of the JobManager service in the DISET framework

The following methods are available in the Service interface

submitJob() rescheduleJob() deleteJob() killJob()

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

Bases: DIRAC.WorkloadManagementSystem.Service.JobManagerHandler.JobManagerHandlerMixin, DIRAC.Core.DISET.RequestHandler.RequestHandler

__init__(handlerInitDict, trid)

Constructor

Parameters

• handlerInitDict (dictionary) – Information vars for the service

• trid (object) – Transport to use

auth_ping = ['all']

auth_refreshConfiguration = ['CSAdministrator']

auth_whoami = ['all']

export_confirmBulkSubmission(jobIDs)

Confirm the possibility to proceed with processing of the jobs specified by the jobIDList

Parameters

jobIDs (list) – list of job IDs

Returns

S_OK(list)/S_ERROR() – confirmed job IDs

export_deleteJob(jobIDs)

Delete jobs specified in the jobIDs list

Parameters

jobIDs (list) – list of job IDs

Returns

S_OK/S_ERROR

static export_echo(data)

This method is used for testing performance of the service

Parameters

data (str) – data to be sent back to the caller

Returns

S_OK, Value is the input data

export_getMaxParametricJobs()

Get the maximum number of parametric jobs

Returns

S_OK()/S_ERROR()

export_killJob(jobIDs)

Kill jobs specified in the jobIDs list

Parameters

jobIDs (list) – list of job IDs

Returns

S_OK/S_ERROR

export_ping()

static export_refreshConfiguration(fromMaster)

Force refreshing the configuration data

Parameters

fromMaster (bool) – flag to refresh from the master configuration service

export_removeJob(jobIDs)

Completely remove a list of jobs, also from TaskQueueDB, and including its JobLogging info. Only authorized users are allowed to remove jobs.

Parameters

jobIDs (list) – list of job IDs

Returns

S_OK()/S_ERROR() – confirmed job IDs

export_rescheduleJob(jobIDs)

Reschedule a single job. If the optional proxy parameter is given it will be used to refresh the proxy in the Proxy Repository

Parameters

jobIDs (list) – list of job IDs

Returns

S_OK()/S_ERROR() – confirmed job IDs

export_resetJob(jobIDs)

Reset jobs specified in the jobIDs list

Parameters

jobIDs (list) – list of job IDs

Returns

S_OK/S_ERROR

export_submitJob(jobDesc)

Submit a job to DIRAC WMS. The job can be a single job, or a parametric job. If it is a parametric job, then the parameters will need to be unpacked.

Parameters

jobDesc (str) – job description JDL (of a single or parametric job)

Returns

S_OK/S_ERROR, a list of newly created job IDs in case of S_OK.

export_whoami()

A simple whoami, returns all credential dictionary, except certificate chain object.

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)

classmethod initializeHandler(serviceInfoDict)

Initialization of DB objects and OptimizationMind

initializeRequest()

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

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_confirmBulkSubmission = [<class 'list'>]

types_deleteJob = []

types_echo = [(<class 'str'>,)]

types_getMaxParametricJobs = []

types_killJob = []

types_ping = []

types_refreshConfiguration = [<class 'bool'>]

types_removeJob = []

types_rescheduleJob = []

types_resetJob = []

types_submitJob = [(<class 'str'>,)]

types_whoami = []

class DIRAC.WorkloadManagementSystem.Service.JobManagerHandler.JobManagerHandlerMixin

Bases: object

RequestHandler implementation of the JobManager

export_confirmBulkSubmission(jobIDs)

Confirm the possibility to proceed with processing of the jobs specified by the jobIDList

Parameters

jobIDs (list) – list of job IDs

Returns

S_OK(list)/S_ERROR() – confirmed job IDs

export_deleteJob(jobIDs)

Delete jobs specified in the jobIDs list

Parameters

jobIDs (list) – list of job IDs

Returns

S_OK/S_ERROR

export_getMaxParametricJobs()

Get the maximum number of parametric jobs

Returns

S_OK()/S_ERROR()

export_killJob(jobIDs)

Kill jobs specified in the jobIDs list

Parameters

jobIDs (list) – list of job IDs

Returns

S_OK/S_ERROR

export_removeJob(jobIDs)

Completely remove a list of jobs, also from TaskQueueDB, and including its JobLogging info. Only authorized users are allowed to remove jobs.

Parameters

jobIDs (list) – list of job IDs

Returns

S_OK()/S_ERROR() – confirmed job IDs

export_rescheduleJob(jobIDs)

Reschedule a single job. If the optional proxy parameter is given it will be used to refresh the proxy in the Proxy Repository

Parameters

jobIDs (list) – list of job IDs

Returns

S_OK()/S_ERROR() – confirmed job IDs

export_resetJob(jobIDs)

Reset jobs specified in the jobIDs list

Parameters

jobIDs (list) – list of job IDs

Returns

S_OK/S_ERROR

export_submitJob(jobDesc)

Submit a job to DIRAC WMS. The job can be a single job, or a parametric job. If it is a parametric job, then the parameters will need to be unpacked.

Parameters

jobDesc (str) – job description JDL (of a single or parametric job)

Returns

S_OK/S_ERROR, a list of newly created job IDs in case of S_OK.

classmethod initializeHandler(serviceInfoDict)

Initialization of DB objects and OptimizationMind

initializeRequest()

types_confirmBulkSubmission = [<class 'list'>]

types_deleteJob = []

types_getMaxParametricJobs = []

types_killJob = []

types_removeJob = []

types_rescheduleJob = []

types_resetJob = []

types_submitJob = [(<class 'str'>,)]