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

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(cls, 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

setJobFlag(cls, jobID, flag, **kwargs)

Set job flag for job with jobID

Automatically created for the service function export_setJobFlag()

Parameters:

• jobID – jobID

• flag – flag

setJobParameter(cls, 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(cls, 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(cls, jobID, status, minorStatus, source, datetime, force, **kwargs)

Sets the major and minor status for job specified by its JobId. Sets optionally the status date and source component which sends the status information. The “force” flag will override the WMS state machine decision.

Automatically created for the service function export_setJobStatus()

Parameters:

• jobID – jobID

• status – status

• minorStatus – minorStatus

• source – source

• datetime – datetime

• force – force

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(cls, 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

unsetJobFlag(cls, jobID, flag, **kwargs)

Unset job flag for job with jobID

Automatically created for the service function export_unsetJobFlag()

Parameters:

• jobID – jobID

• flag – flag

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