From 1da78397c3c7cd7ee397c1b7fa96d9d5ec803bf2 Mon Sep 17 00:00:00 2001
From: Logan Hanks <logan@reddit.com>
Date: Wed, 17 Oct 2012 14:03:12 -0700
Subject: [PATCH] Make @g.stats.amqp_processor flush stats.

---
 r2/r2/lib/stats.py | 1 +
 1 file changed, 1 insertion(+)

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