diff --git a/services/db.py b/services/db.py
index 085ab80f..93f5b091 100644
--- a/services/db.py
+++ b/services/db.py
@@ -92,6 +92,7 @@ warnings.simplefilter('always', exc.SAWarning)
 @event.listens_for(Engine, 'before_cursor_execute')
 def before_cursor_execute(conn, cursor, statement, parameters, context, executemany):
     conn.query_start_time = time.time()
+    conn.statement = statement
 
 
 # noinspection PyUnusedLocal
@@ -101,5 +102,6 @@ def after_cursor_execute(conn, cursor, statement, parameters, context, executema
         elapsed = time.time() - conn.query_start_time
         conn.query_start_time = None
         query = f'{statement} % {parameters}' if parameters else f'{statement}'.replace('\n', ' ')
-        if elapsed > 1:
+        if elapsed > 1 and conn.executed_statement != conn.statement:
+            conn.executed_statement = conn.statement
             logger.debug(f"\n{query}\n{'*' * math.floor(elapsed)} {elapsed:.3f} s\n")