flux.job.stats module

class flux.job.stats.JobStats(handle, queue=None)

Bases: object

Container for job statistics as returned by job-list.job-stats

depend

Count of jobs current in DEPEND state

priority

Count of jobs in PRIORITY state

sched

Count of jobs in SCHED state

run

Count of jobs in RUN state

cleanup

Count of jobs in CLEANUP state

inactive

Count of INACTIVE jobs

successful

Total number of jobs completed with zero exit code

failed

Total number of jobs that did not exit with zero status

timeout

Total number of jobs that timed out

canceled

Total number of jobs that were canceled

pending

Sum of "depend", "priority", and "sched"

running

Sum of "run" and "cleanup"

active

Total number of active jobs (all states but INACTIVE)

update(callback=None, **kwargs)

Asynchronously fetch job statistics and update this object.

Requires that the reactor for this handle be running in order to process the result.

Parameters

• callback -- Optional: a callback to call when asynchronous update is complete.

• kwargs -- Optional: extra keyword arguments to pass to callback()

update_sync()

Synchronously update job statistics