diff --git a/roles/provision_slurm/templates/provision_slurm.py.j2 b/roles/provision_slurm/templates/provision_slurm.py.j2 index 986d7c153d9fb73f10bb1642f21adb80a2029500..3639d3430bb1d059c583dbec994467665a32550b 100644 --- a/roles/provision_slurm/templates/provision_slurm.py.j2 +++ b/roles/provision_slurm/templates/provision_slurm.py.j2 @@ -45,14 +45,17 @@ def get_users(server): def mk_slurmaccount(acct): - output=subprocess.check_output(["{{ slurm_dir }}/bin/sacctmgr","--noheader","list","account",acct]) + p=subprocess.Popen(["{{ slurm_dir }}/bin/sacctmgr","--noheader","list","account",acct],stdout=subprocess.PIPE,stderr=subprocess.PIPE) + (output,error)=p.communicate() if acct in output: return else: subprocess.call(["{{ slurm_dir }}/bin/sacctmgr","-i","create","account",acct]) def mk_slurmuser(user,acct): - output=subprocess.check_output(["{{ slurm_dir }}/bin/sacctmgr","--noheader","list","Association","user=%s"%user,"format=account"]) + p=subprocess.Popen(["{{ slurm_dir }}/bin/sacctmgr","--noheader","list","Association","user=%s"%user,"format=account"],stdout=subprocess.PIPE,stderr=subprocess.PIPE) + + (output,error)=p.communicate() if acct in output.splitlines(): return else: