Skip to content

Commit

Permalink
fix priority
Browse files Browse the repository at this point in the history
  • Loading branch information
francesconazzaro committed Feb 12, 2025
1 parent f3461b1 commit 2d8c3ba
Showing 1 changed file with 6 additions and 5 deletions.
11 changes: 6 additions & 5 deletions cads_broker/database.py
Original file line number Diff line number Diff line change
Expand Up @@ -723,16 +723,17 @@ def set_request_status(
"""Set the status of a request."""
statement = sa.select(SystemRequest).where(SystemRequest.request_uid == request_uid)
request = session.scalars(statement).one()
if resubmit:
# ugly implementation because sqlalchemy doesn't allow to directly update JSONB
# FIXME: use a specific column for resubmit_number
metadata = dict(request.request_metadata)
# ugly implementation because sqlalchemy doesn't allow to directly update JSONB
# FIXME: use a specific column for resubmit_number
metadata = dict(request.request_metadata)
if resubmit is not None:
metadata.update(
{"resubmit_number": request.request_metadata.get("resubmit_number", 0) + 1}
)
request.request_metadata = metadata
if priority is not None:
request.request_metadata["priority"] = priority
metadata.update({"priority": priority})
request.request_metadata = metadata
if status == "successful":
request.finished_at = sa.func.now()
elif status == "failed":
Expand Down

0 comments on commit 2d8c3ba

Please sign in to comment.