JobStateUpdateClient

Class that contains client access to the JobStateUpdate handler.

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

Bases: DIRAC.Core.Base.Client.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
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
getServer()

Getter for the server url. Useful ?

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(self, jobID, appStatus, source, **kwargs)

Set the application status for job specified by its JobId.

Automatically created for the service function export_setJobApplicationStatus()

Parameters:
  • jobID – jobID
  • appStatus – appStatus
  • source – source
setJobFlag(self, jobID, flag, **kwargs)

Set job flag for job with jobID

Automatically created for the service function export_setJobFlag()

Parameters:
  • jobID – jobID
  • flag – flag
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(self, 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(self, jobID, status, minorStatus, source, datetime, **kwargs)

Set the major and minor status for job specified by its JobId. Set optionally the status date and source component which sends the status information.

Automatically created for the service function export_setJobStatus()

Parameters:
  • jobID – jobID
  • status – status
  • minorStatus – minorStatus
  • source – source
  • datetime – datetime
setJobStatusBulk(self, jobID, statusDict, **kwargs)

Set various status fields for job specified by its JobId. Set only the last status in the JobDB, updating all the status logging information in the JobLoggingDB. The statusDict has datetime as a key and status information dictionary as values

Automatically created for the service function export_setJobStatusBulk()

Parameters:
  • jobID – jobID
  • statusDict – statusDict
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
setJobsStatus(self, jobIDs, status, minorStatus, source, datetime, **kwargs)

Set the major and minor status for job specified by its JobId. Set optionally the status date and source component which sends the status information.

Automatically created for the service function export_setJobsStatus()

Parameters:
  • jobIDs – jobIDs
  • status – status
  • minorStatus – minorStatus
  • source – source
  • datetime – datetime
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>

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

Unset job flag for job with jobID

Automatically created for the service function export_unsetJobFlag()

Parameters:
  • jobID – jobID
  • flag – flag
updateJobFromStager(self, 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