particle-os/debian-koji
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

use db_lock in protonmsg

Browse source
This commit is contained in:
Mike McLean 2023-03-31 23:22:32 -04:00 • committed by Tomas Kopecek
parent 0d61c94250
commit 4913bd0c0a
1 changed files with 2 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

6
plugins/hub/protonmsg.py
View file

@ -18,7 +18,7 @@ import koji
from koji.context import context
from koji.plugin import callback, convert_datetime, ignore_error
from kojihub import get_build_type
from kojihub.db import QueryProcessor, InsertProcessor, DeleteProcessor
from kojihub.db import QueryProcessor, InsertProcessor, DeleteProcessor, db_lock
CONFIG_FILE = '/etc/koji-hub/plugins/protonmsg.conf'
CONFIG = None
@ -361,9 +361,7 @@ def handle_db_msgs(urls, CONFIG):
c = context.cnx.cursor()
# we're running in postCommit, so we need to handle new transaction
c.execute('BEGIN')
try:
c.execute('LOCK TABLE proton_queue IN ACCESS EXCLUSIVE MODE NOWAIT', log_errors=False)
except psycopg2.OperationalError:
if not db_lock('protonmsg-plugin', wait=False):
LOG.debug('skipping db queue due to lock')
return
try: