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

Age in protonmsg config file is deprecated

Browse source 
Fixes: https://pagure.io/koji/issue/3332
This commit is contained in:
Jana Cupova 2022-04-27 12:16:28 +02:00 • committed by Tomas Kopecek
parent f72f033465
commit ff500a2c4e
1 changed files with 6 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

8
plugins/hub/protonmsg.py
View file

@ -361,8 +361,12 @@ def handle_db_msgs(urls, CONFIG):
LOG.debug('skipping db queue due to lock') LOG.debug('skipping db queue due to lock')
return return
try: try:
c.execute("DELETE FROM proton_queue WHERE created_ts < NOW() -'%s hours'::interval" % max_age = CONFIG.getint('queue', 'max_age', fallback=None)
CONFIG.getint('queue', 'age', fallback=24)) if not max_age:
# age in config file is deprecated
max_age = CONFIG.getint('queue', 'age', fallback=24)
c.execute("DELETE FROM proton_queue WHERE created_ts < NOW() -'%s hours'::interval"
% max_age)
query = QueryProcessor(tables=('proton_queue',), query = QueryProcessor(tables=('proton_queue',),
columns=('id', 'address', 'props', 'body::TEXT'), columns=('id', 'address', 'props', 'body::TEXT'),
aliases=('id', 'address', 'props', 'body'), aliases=('id', 'address', 'props', 'body'),