Fix syntax error from trying to add stats collection to the solrsearch queue.

This commit is contained in:
Logan Hanks
2011-11-09 12:21:57 -07:00
parent 43dbcfc4ee
commit 7fed17d014

View File

@@ -667,6 +667,7 @@ def run_changed(drain=False):
last run. Note: unlike many queue-using functions, this one is
run from cron and totally drains the queue before terminating
"""
@g.stats.amqp_processor
def _run_changed(msgs, chan):
print "changed: Processing %d items" % len(msgs)
msgs = [strordict_fullname(msg.body)
@@ -687,6 +688,5 @@ def run_changed(drain=False):
for i in delete_things:
s.delete(id=i._fullname)
@g.stats.amqp_processor
amqp.handle_items('solrsearch_changes', _run_changed, limit=1000,
drain=drain)