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

protonmsg: cast body to text

Browse source
This commit is contained in:
Yu Ming Zhu 2021-07-10 07:29:29 +00:00 • committed by Tomas Kopecek
parent 012a2eb83b
commit 243e114b1f
1 changed files with 2 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

3
plugins/hub/protonmsg.py
View file

@ -347,7 +347,8 @@ def handle_db_msgs(urls, CONFIG):
c.execute("DELETE FROM proton_queue WHERE created_ts < NOW() -'%s hours'::interval" %
CONFIG.getint('queue', 'age', fallback=24))
query = QueryProcessor(tables=('proton_queue',),
columns=('id', 'address', 'props', 'body'),
columns=('id', 'address', 'props', 'body::TEXT'),
aliases=('id', 'address', 'props', 'body'),
opts={'order': 'id', 'limit': limit})
msgs = list(query.execute())
if not msgs: