Commit after changing job state

This commit is contained in:
mvdbeek
2024-04-03 19:19:40 +02:00
parent 16e0e4b775
commit 061d4c32db
+2 -1
View File
@@ -1697,9 +1697,10 @@ class Job(Base, JobLike, UsesCreateAndUpdateTime, Dictifiable, Serializable):
.where(Job.id == self.id, ~Job.state.in_((state, *Job.finished_states)))
.values(state=state)
)
with transaction(session):
session.commit()
if rval.rowcount == 1:
# Need to expire state since we just updated it, but ORM doesn't know about it.
session.expire(self, ["state"])
self.state_history.append(JobStateHistory(self))
return True
else: