one sec join in test

celery/app/amqp.py

@@ -28,6 +28,7 @@ QUEUE_FORMAT = """
 . %(name)s exchange:%(exchange)s(%(exchange_type)s) binding:%(routing_key)s
 """
 
+
 class Queues(dict):
     """Queue name⇒ declaration mapping.
 

celery/bin/celery.py

@@ -84,6 +84,7 @@ def load_extension_commands(namespace='celery.commands'):
         else:
             command(cls, name=ep.name)
 
+
 class Command(BaseCommand):
     help = ''
     args = ''

celery/contrib/migrate.py

@@ -11,7 +11,7 @@ from __future__ import with_statement
 
 import socket
 
-from functools import partial, wraps
+from functools import partial
 from itertools import cycle, islice
 
 from kombu import eventloop, Queue

celery/tests/worker/test_worker.py

@@ -476,7 +476,7 @@ class test_Consumer(Case):
         l.update_strategies()
         l.receive_message(m.decode(), m)
         l.timer.stop()
-        l.timer.join()
+        l.timer.join(1)
 
         items = [entry[2] for entry in self.timer.queue]
         found = 0