JobManagerClient

Class that contains client access to the JobManager handler.

class DIRAC.WorkloadManagementSystem.Client.JobManagerClient.JobManagerClient(url=None, **kwargs)

Bases: DIRAC.Core.Base.Client.Client

JobManagerClient sets url for the JobManagerHandler.

__init__(url=None, **kwargs)

Sets URL for JobManager handler

Parameters:
  • self – self reference
  • url – url of the JobManagerHandler
  • kwargs – forwarded to the Base Client class
confirmBulkSubmission(self, jobIDs, **kwargs)

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

Automatically created for the service function export_confirmBulkSubmission()

deleteJob(self, jobIDs, **kwargs)

Delete jobs specified in the jobIDs list

Parameters:jobIDs (list) – list of job IDs
Returns:S_OK/S_ERROR

Automatically created for the service function export_deleteJob()

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
getMaxParametricJobs(self, **kwargs)

Get the maximum number of parametric jobs

Returns:S_OK()/S_ERROR()

Automatically created for the service function export_getMaxParametricJobs()

getServer()

Getter for the server url. Useful ?

killJob(self, jobIDs, **kwargs)

Kill jobs specified in the jobIDs list

Parameters:jobIDs (list) – list of job IDs
Returns:S_OK/S_ERROR

Automatically created for the service function export_killJob()

rescheduleJob(self, jobIDs, **kwargs)

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

Automatically created for the service function export_rescheduleJob()

resetJob(self, jobIDs, **kwargs)

Reset jobs specified in the jobIDs list

Parameters:jobIDs (list) – list of job IDs
Returns:S_OK/S_ERROR

Automatically created for the service function export_resetJob()

setServer(url)

Set the server URL used by default

Parameters:url – url of the service
setTimeout(**kwargs)

Specify the timeout of the call. Forwarded to RPCClient

param int timeout:
 timeout for the RPC calls

Deprecated: Please use self._getRPC(timeout) or self.timeout=<value>

submitJob(self, jobDesc, **kwargs)

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.

Automatically created for the service function export_submitJob()