From 666ea91e473554acabe6f6c3477eb915e70a7538 Mon Sep 17 00:00:00 2001 From: Nat Lasseter Date: Mon, 16 Mar 2020 10:15:21 +0000 Subject: Refactor: renamed jobs to raiders, becaus pun, and jobs is confusing given the intended application of longboat by the original authors. --- lib/jobs/slurm_job_states.rb | 41 ----------------------------------------- 1 file changed, 41 deletions(-) delete mode 100644 lib/jobs/slurm_job_states.rb (limited to 'lib/jobs') 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 -- cgit v1.2.1