Merge "DB: Select upon delete for allocations"

This commit is contained in:
Zuul 2023-07-31 00:38:35 +00:00 committed by Gerrit Code Review
commit ee77f0b40d
1 changed files with 5 additions and 1 deletions

View File

@ -2392,7 +2392,11 @@ class Connection(api.Connection):
query = add_identity_filter(query, allocation_id)
try:
ref = query.one()
# NOTE(TheJulia): We explicitly need to indicate we intend
# to update the record so we block until the other users of
# the row are free, such as the process to match the
# allocation to a node.
ref = query.with_for_update().one()
except NoResultFound:
raise exception.AllocationNotFound(allocation=allocation_id)