From fcd89dc007a5a73db900ed7d11a39ac0ce44207c Mon Sep 17 00:00:00 2001 From: Ricky Ramirez Date: Tue, 16 Jul 2013 15:54:30 -0700 Subject: [PATCH] cloudsearch: Decorate cloudsearch_q with stats. --- r2/r2/lib/cloudsearch.py | 1 + 1 file changed, 1 insertion(+) diff --git a/r2/r2/lib/cloudsearch.py b/r2/r2/lib/cloudsearch.py index de9dda661..3704a3160 100644 --- a/r2/r2/lib/cloudsearch.py +++ b/r2/r2/lib/cloudsearch.py @@ -576,6 +576,7 @@ def chunk_xml(xml, depth=0): yield chunk +@g.stats.amqp_processor('cloudsearch_q') def _run_changed(msgs, chan): '''Consume the cloudsearch_changes queue, and print reporting information on how long it took and how many remain