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)

class QueueStats(stats=None)

Bases: object

Container for a set of per-queue stats

derived_stats = ('pending', 'running', 'active')

states = ('depend', 'priority', 'sched', 'run', 'cleanup', 'inactive', 'total')

stats = ('successful', 'failed', 'timeout', 'canceled', 'inactive_purged')

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