From 202c9d9fcc65afb8b2a6a7500ee4581ee03cea45 Mon Sep 17 00:00:00 2001 From: kindly Date: Thu, 15 Nov 2012 14:21:09 +0000 Subject: [PATCH] use correct queue for gather stage --- ckanext/harvest/commands/harvester.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ckanext/harvest/commands/harvester.py b/ckanext/harvest/commands/harvester.py index 02a2d11..654a880 100644 --- a/ckanext/harvest/commands/harvester.py +++ b/ckanext/harvest/commands/harvester.py @@ -114,7 +114,7 @@ class Harvester(CkanCommand): from ckanext.harvest.queue import get_gather_consumer, gather_callback logging.getLogger('amqplib').setLevel(logging.INFO) consumer = get_gather_consumer() - for method, header, body in consumer.consume(queue='ckan.harvest.fetch'): + for method, header, body in consumer.consume(queue='ckan.harvest.gather'): gather_callback(consumer, method, header, body) elif cmd == 'fetch_consumer': import logging