From 8295fff88207eac51e514d6ac085385c2ef4b71c Mon Sep 17 00:00:00 2001 From: Magnus Hagander Date: Wed, 19 Jun 2019 18:46:55 +0200 Subject: [PATCH] Actually enforce rate limiting Forgot to commit the changes to the sender --- resender/archives_resender.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/resender/archives_resender.py b/resender/archives_resender.py index 061ea16..83bb10d 100755 --- a/resender/archives_resender.py +++ b/resender/archives_resender.py @@ -16,7 +16,7 @@ import psycopg2 def process_queue(conn, sender, smtpserver, heloname): with conn.cursor() as curs: - curs.execute("SELECT r.id, u.email, m.rawtxt FROM mailarchives_resendmessage r INNER JOIN auth_user u ON u.id=r.sendto_id INNER JOIN messages m ON m.id=r.message_id ORDER BY r.id FOR UPDATE OF r LIMIT 1") + curs.execute("SELECT r.id, u.email, m.rawtxt FROM mailarchives_resendmessage r INNER JOIN auth_user u ON u.id=r.sendto_id INNER JOIN messages m ON m.id=r.message_id WHERE registeredat > CURRENT_TIMESTAMP ORDER BY r.id FOR UPDATE OF r LIMIT 1") ll = curs.fetchall() if len(ll) == 0: conn.rollback() -- 2.39.5