aboutsummaryrefslogtreecommitdiff
path: root/lib/jobs
diff options
context:
space:
mode:
Diffstat (limited to 'lib/jobs')
-rw-r--r--lib/jobs/slurm_job_states.rb41
1 files changed, 0 insertions, 41 deletions
diff --git a/lib/jobs/slurm_job_states.rb b/lib/jobs/slurm_job_states.rb
deleted file mode 100644
index 1211f11..0000000
--- a/lib/jobs/slurm_job_states.rb
+++ /dev/null
@@ -1,41 +0,0 @@
-class SlurmJobStates
- def initialize(collector, config)
- @collector = collector
- @interval = config[:collect_every]
- end
-
- def run
- start_time = (Time.now - @interval).strftime("%H:%M:%S")
-
- # Get raw data from sacct,
- # read jobs into an array,
- # remove any whitespace from the ends of each string,
- # drop the header,
- # and split each line into state and partition
- raw = `sacct -a -P -o State,Partition -S #{start_time}`.
- lines.
- map(&:strip)[1..-1].
- map{|l|l.split("|")}
-
- # Make a tally of each state/partition combo
- tally = Hash.new{0}
- raw.each do |job|
- tally[job] += 1
- end
-
- # Clean up any previously reported metrics
- # to prevent stale labelsets
- @collector.redact!("slurm_job_states")
-
- # Report new metrics
- tally.each do |labelset, number|
- @collector.report!(
- "slurm_job_states",
- number,
- help: "Number of jobs in each state",
- type: "gauge",
- labels: {state: labelset[0], partition: labelset[1]}
- )
- end
- end
-end