diff --git a/pysqa/wrapper/flux.py b/pysqa/wrapper/flux.py index 401d2baa..bd8404e9 100644 --- a/pysqa/wrapper/flux.py +++ b/pysqa/wrapper/flux.py @@ -25,20 +25,11 @@ def get_job_id_from_output(queue_submit_output): def convert_queue_status(queue_status_output): line_split_lst = [line.split() for line in queue_status_output.splitlines()] job_id_lst, user_lst, job_name_lst, status_lst = [], [], [], [] - for ( - flux_id, - user, - job_name, - status, - task, - nodes, - runtime, - ranks, - ) in line_split_lst: - job_id_lst.append(JobID(flux_id)) - user_lst.append(user) - job_name_lst.append(job_name) - status_lst.append(status) + for entry in line_split_lst: + job_id_lst.append(JobID(entry[0])) + user_lst.append(entry[1]) + job_name_lst.append(entry[2]) + status_lst.append(entry[3]) df = pandas.DataFrame( { "jobid": job_id_lst,