Commit 70fbc731 authored by Martin Schorb's avatar Martin Schorb
Browse files

sparkslurm runstatus

parent c6386314
......@@ -235,7 +235,10 @@ def cluster_status(run_state):
elif 'PENDING' in slurm_stat:
out_stat.append('pending')
elif 'CANCELLED' in slurm_stat:
out_stat.append('cancelled')
if run_state['status'] == 'done':
out_stat.append('done')
else:
out_stat.append('cancelled')
else:
out_stat.append('launch')
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment