From e71cf355041d2b828d5e86fc1958414919d3576e Mon Sep 17 00:00:00 2001 From: amercader Date: Fri, 20 Nov 2015 14:25:31 +0000 Subject: [PATCH] Fix queue tests --- ckanext/harvest/tests/test_queue.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/ckanext/harvest/tests/test_queue.py b/ckanext/harvest/tests/test_queue.py index e7db75d69..bc17c15ec 100644 --- a/ckanext/harvest/tests/test_queue.py +++ b/ckanext/harvest/tests/test_queue.py @@ -93,8 +93,10 @@ def setup_class(cls): def test_01_basic_harvester(self): ### make sure queues/exchanges are created first and are empty - consumer = queue.get_consumer('ckan.harvest.test.gather', 'harvest_job_id') - consumer_fetch = queue.get_consumer('ckan.harvest.test.fetch', 'harvest_object_id') + consumer = queue.get_consumer('ckan.harvest.test.gather', + queue.get_gather_routing_key()) + consumer_fetch = queue.get_consumer('ckan.harvest.test.fetch', + queue.get_fetch_routing_key()) consumer.queue_purge(queue='ckan.harvest.test.gather') consumer_fetch.queue_purge(queue='ckan.harvest.test.fetch')