diff --git a/scheduler/rdbms/postgres/RetrieveJobQueue.cpp b/scheduler/rdbms/postgres/RetrieveJobQueue.cpp index accdfc05d8031403daabfd06a8f81cbadf038651..6d0c94224b782bb2de8937edaa7da44735a65d05 100644 --- a/scheduler/rdbms/postgres/RetrieveJobQueue.cpp +++ b/scheduler/rdbms/postgres/RetrieveJobQueue.cpp @@ -709,6 +709,7 @@ RetrieveJobQueueRow::transformJobBatchToArchive(Transaction& txn, const size_t l WHERE STATUS = :RETRIEVESTATUS ORDER BY JOB_ID LIMIT :LIMIT + FOR UPDATE SKIP LOCKED ) RETURNING rraq.*, COALESCE(