JobStateUpdateClient

Class that contains client access to the JobStateUpdate handler.

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

Bases: Client

JobStateUpdateClient sets url for the JobStateUpdateHandler.

__init__(url=None, **kwargs)

Sets URL for JobStateUpdate handler

Parameters:

• self – self reference

• url – url of the JobStateUpdateHandler

• kwargs – forwarded to the Base Client class

property call

To be removed once we’re sure self.call has been removed

Type:

Deprecated

diracxClient

alias of JobStateUpdateClient

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

getClientKWArgs()

Returns a copy of the connection arguments

getServer()

Getter for the server url. Useful ?

httpsClient

alias of TornadoClient

sendHeartBeat(self, jobID, dynamicData, staticData, **kwargs)

Send a heart beat sign of life for a job jobID

Automatically created for the service function export_sendHeartBeat()

Parameters:

• jobID – jobID

• dynamicData – dynamicData

• staticData – staticData

setJobApplicationStatus(cls, jobID, appStatus, source, **kwargs)

Set the application status for job specified by its JobId. Internally calling the bulk method

Automatically created for the service function export_setJobApplicationStatus()

Parameters:

• jobID – jobID

• appStatus – appStatus

• source – source

setJobAttribute(cls, jobID, attribute, value, **kwargs)

Set a job attribute

Automatically created for the service function export_setJobAttribute()

Parameters:

• jobID – jobID

• attribute – attribute

• value – value

setJobParameter(self, jobID, name, value, **kwargs)

Set arbitrary parameter specified by name/value pair for job specified by its JobId

Automatically created for the service function export_setJobParameter()

Parameters:

• jobID – jobID

• name – name

• value – value

setJobParameters(self, jobID, parameters, **kwargs)

Set arbitrary parameters specified by a list of name/value pairs for job specified by its JobId

Automatically created for the service function export_setJobParameters()

Parameters:

• jobID – jobID

• parameters – parameters

setJobSite(cls, jobID, site, **kwargs)

Allows the site attribute to be set for a job specified by its jobID.

Automatically created for the service function export_setJobSite()

Parameters:

• jobID – jobID

• site – site

setJobStatus(jobID, status='', minorStatus='', source='Unknown', datetime_=None, force=False, **kwargs)

setJobStatusBulk(cls, jobID, statusDict, force, **kwargs)

Set various job status fields with a time stamp and a source

Automatically created for the service function export_setJobStatusBulk()

Parameters:

• jobID – jobID

• statusDict – statusDict

• force – force

setJobsParameter(self, jobsParameterDict, **kwargs)

Set arbitrary parameter specified by name/value pair for job specified by its JobId

Automatically created for the service function export_setJobsParameter()

Parameters:

jobsParameterDict – jobsParameterDict

setServer(url)

Set the server URL used by default

Parameters:

url – url of the service

updateJobFromStager(cls, jobID, status, **kwargs)

Simple call back method to be used by the stager.

Automatically created for the service function export_updateJobFromStager()

Parameters:

• jobID – jobID

• status – status