diff --git a/roles/telegraf/files/telegraf_slurmstats.py b/roles/telegraf/files/telegraf_slurmstats.py index 2f57b3adb4fca1e262ffc4f30b2814f13e5e5ab0..7fdf895cef43afdb0e6b3ec37aa665e850bbd918 100644 --- a/roles/telegraf/files/telegraf_slurmstats.py +++ b/roles/telegraf/files/telegraf_slurmstats.py @@ -15,7 +15,7 @@ def print_stats(stats): def get_stats(): import subprocess - p = subprocess.Popen(['/opt/slurm-20.02.7/bin/sdiag'],stdout = subprocess.PIPE,stderr=subprocess.PIPE) + p = subprocess.Popen(['/opt/slurm-latest/bin/sdiag'],stdout = subprocess.PIPE,stderr=subprocess.PIPE) (stdout,stderr) = p.communicate() for l in stdout.decode().splitlines(): if "Total backfilled jobs (since last stats cycle start):" in l: diff --git a/roles/telegraf/tasks/main.yml b/roles/telegraf/tasks/main.yml index 39bce93940d3644c881feeeae73f2b75840b4695..76fb855966924cb073ab5af2ec83b961cbdd32b1 100644 --- a/roles/telegraf/tasks/main.yml +++ b/roles/telegraf/tasks/main.yml @@ -57,6 +57,11 @@ become: true become_user: root +- name: check if slurm is on the system + stat: + path: '/opt/slurm-latest/bin/sdiag' + register: checkslurmexists + - name: copy slurmstats plugin copy: mode: 'u=rwx,g=rx,o=rx' @@ -64,6 +69,7 @@ dest: '/opt/telegraf/bin/telegraf_slurmstats.py' become: true become_user: root + when: checkslurmexists.stat.exists - name: copy softnet_stat script copy: