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

protonmsg: actually remove messages from db queue

Browse source 
Fixes: https://pagure.io/koji/issue/2846
This commit is contained in:
Mike McLean 2021-05-06 15:07:14 -04:00 • committed by Tomas Kopecek
parent 4b55b62355
commit 5045f96bb4
1 changed files with 3 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

5
plugins/hub/protonmsg.py
View file

@ -354,9 +354,10 @@ def handle_db_msgs(urls, CONFIG):
LOG.debug('test mode: skipping send for %i messages from db', len(msgs))
unsent = []
else:
unsent = {m['id'] for m in _send_msgs(urls, msgs, CONFIG)}
# we pass a copy of msgs because _send_msgs modifies it
unsent = {m['id'] for m in _send_msgs(urls, list(msgs), CONFIG)}
sent = [m for m in msgs if m['id'] not in unsent]
if msgs:
if sent:
c.execute('DELETE FROM proton_queue WHERE id IN %(ids)s',
{'ids': [msg['id'] for msg in sent]})
finally: