cloudsearch: Decorate cloudsearch_q with stats.

This commit is contained in:
Ricky Ramirez
2013-07-16 15:54:30 -07:00
committed by Chad Birch
parent 833b717dd5
commit fcd89dc007

View File

@@ -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