diff --git a/roles/telegraf/files/telegraf_slurmstats.py b/roles/telegraf/files/telegraf_slurmstats.py
index 962a2080abbeb1a5532045bce4beb5a51f0033b7..2f57b3adb4fca1e262ffc4f30b2814f13e5e5ab0 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(['sdiag'],stdout = subprocess.PIPE,stderr=subprocess.PIPE)
+    p = subprocess.Popen(['/opt/slurm-20.02.7/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: