Skip to content
Snippets Groups Projects
Verified Commit a655872c authored by Dorian Koch's avatar Dorian Koch
Browse files

Deleted -> Canceled

parent 25488dda
Branches
Tags
No related merge requests found
doc/job_states.drawio.png

62.4 KiB | W: | H:

doc/job_states.drawio.png

62.7 KiB | W: | H:

doc/job_states.drawio.png
doc/job_states.drawio.png
doc/job_states.drawio.png
doc/job_states.drawio.png
  • 2-up
  • Swipe
  • Onion skin
......@@ -60,7 +60,7 @@ class WatchJob(GeneratorRecurringEvent):
old_id = self.job.refresh_data(cstate)
if self.job.jobData is None:
raise Exception(f"Could not find job in db with id={old_id}")
if self.job.job_state == JobState.DELETED or self.job.job_state == JobState.FINISHED_AND_PROCESSED or self.job.job_state == JobState.FAILED_AND_PROCESSED:
if self.job.job_state == JobState.CANCELED or self.job.job_state == JobState.FINISHED_AND_PROCESSED or self.job.job_state == JobState.FAILED_AND_PROCESSED:
print(f"Job already processed in db, state: {self.job.job_state}, not processing again")
return
expected_state = JobState.FINISHED if job_info.status.succeeded is not None else JobState.FAILED
......
......@@ -13,7 +13,7 @@ class JobState(Enum):
FINISHED_AND_PROCESSED = "finished_and_processed"
FAILED = "failed"
FAILED_AND_PROCESSED = "failed_and_processed"
DELETED = "deleted"
CANCELED = "canceled"
class JobData():
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment