JobReport

JobReport class encapsulates various methods of the job status reporting. It’s an interface to JobStateUpdateClient, used when bulk submission is needed.

class DIRAC.WorkloadManagementSystem.Client.JobReport.JobReport(jobid, source='')

Bases: object

class JobReport

__init__(jobid, source='')

c’tor

commit()

Send all the accumulated information

dump()

Print out the contents of the internal cached information

generateForwardDISET()

Generate and return failover requests for the operations in the internal cache

sendStoredJobParameters()

Send the job parameters stored in the internal cache

sendStoredStatusInfo()

Send the job status information stored in the internal cache

setApplicationStatus(appStatus, sendFlag=True)

Send application status information to the JobState service for jobID

setJob(jobID)

Set the job ID for which to send reports

setJobParameter(par_name, par_value, sendFlag=True)

Set job parameter for jobID

setJobParameters(parameters, sendFlag=True)

Set job parameters for jobID

setJobStatus(status='', minorStatus='', applicationStatus='', sendFlag=True)

Accumulate and possibly send job status information to the JobState service

DIRAC.WorkloadManagementSystem.Client.JobReport.isFiniteParameterValue(value)

Check that a job parameter value holds no non-finite number.

Non-finite floats (NaN, +/-Infinity) have no representation in JSON: they make the encoded payload invalid, which the receiving side rejects outright. Values are inspected recursively, since a parameter may well be a container.

Parameters:

value – any job parameter value

Returns:

False if a NaN or an infinity is found anywhere in value