def update_priority!
return if ![Queued, Locked, Running].include?(state)
p = ContainerRequest.
- where('container_uuid=? and priority>0', uuid).
+ where('container_uuid=? and priority>0 and state=?', uuid, ContainerRequest::Committed).
select("priority, requesting_container_uuid, created_at").
lock(true).
map do |cr|
ContainerRequest.
where(requesting_container_uuid: uuid,
state: ContainerRequest::Committed).
- in_batches(of: 15).each do |cr|
+ in_batches(of: 15).each_record do |cr|
leave_modified_by_user_alone do
cr.set_priority_zero
container_state = Container.where(uuid: cr.container_uuid).pluck(:state).first