Skip to content

Commit

Permalink
Mark cancelled jobs as error
Browse files Browse the repository at this point in the history
  • Loading branch information
jan-janssen committed Apr 24, 2024
1 parent 71432b8 commit b3b3f08
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 1 deletion.
1 change: 1 addition & 0 deletions pysqa/wrapper/flux.py
Original file line number Diff line number Diff line change
Expand Up @@ -43,5 +43,6 @@ def convert_queue_status(queue_status_output: str) -> pandas.DataFrame:
)
df.loc[df.status == "R", "status"] = "running"
df.loc[df.status == "S", "status"] = "pending"
df.loc[df.status == "C", "status"] = "error"
df.loc[df.status == "CD", "status"] = "finished"
return df
2 changes: 1 addition & 1 deletion tests/test_flux.py
Original file line number Diff line number Diff line change
Expand Up @@ -105,4 +105,4 @@ def test_flux_integration(self):
)
self.assertEqual(self.flux.get_status_of_job(process_id=job_id), 'running')
self.flux.delete_job(process_id=job_id)
self.assertEqual(self.flux.get_status_of_job(process_id=job_id), 'C')
self.assertEqual(self.flux.get_status_of_job(process_id=job_id), 'erro')

0 comments on commit b3b3f08

Please sign in to comment.