Permalink
Browse files

Fixed a test suddenly stopped passing after amqplib 0.6.1 (don't even…

… know why

it passed before)
  • Loading branch information...
1 parent 46dc93f commit 89afec030311413d8a3df54eee7e7b203f022021 Ask Solem committed Aug 30, 2009
Showing with 3 additions and 2 deletions.
  1. +3 −2 celery/tests/test_task.py
@@ -273,11 +273,12 @@ def test_counter_taskset(self):
self.assertEquals(ts.task_name, IncrementCounterTask.name)
self.assertEquals(ts.total, 9)
+
+ consumer = IncrementCounterTask().get_consumer()
+ consumer.discard_all()
taskset_res = ts.run()
subtasks = taskset_res.subtasks
taskset_id = taskset_res.taskset_id
-
- consumer = IncrementCounterTask().get_consumer()
for subtask in subtasks:
m = consumer.decoder(consumer.fetch().body)
self.assertEquals(m.get("taskset"), taskset_id)

0 comments on commit 89afec0

Please sign in to comment.