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