diff --git a/r2/r2/lib/stats.py b/r2/r2/lib/stats.py
index a84a23cc8..e52320f21 100644
--- a/r2/r2/lib/stats.py
+++ b/r2/r2/lib/stats.py
@@ -262,6 +262,7 @@ class Stats:
                     service_time = (time.time() - start) / len(msg_tup)
                     for msg in msg_tup:
                         self.transact('amqp.%s' % queue_name, service_time)
+                    self.flush()
             return wrap_processor
         return decorator