Ignore locked rows in multicast dequeue.

This commit is contained in:
Antony 2025-03-27 17:04:04 +13:00
parent 3e7f09db62
commit 31ff6f0c96

View File

@ -675,6 +675,7 @@ pub async fn get_schedulable_queue_items(limit: usize) -> Result<Vec<MulticastGr
order by
qi.created_at
limit $1
for update skip locked
)
returning *
"#