diff --git a/src/common/logger.py b/src/common/logger.py index e61c5ae60..c2739b1d7 100644 --- a/src/common/logger.py +++ b/src/common/logger.py @@ -371,12 +371,7 @@ class Logger: results = self.cur.fetchall() if len(results) == 0: # Log line is no more in logs table. remove it from unread_messages - sql = 'DELETE FROM unread_messages WHERE message_id=%s' % msg_id - self.cur.execute(sql) - try: - self.con.commit() - except sqlite.OperationalError, e: - print >> sys.stderr, str(e) + self.set_read_messages([msg_id]) continue all_messages.append(results[0]) return all_messages