flux.job.stats module
- class flux.job.stats.JobStats(handle, queue=None)
Bases:
objectContainer 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