@@ -467,7 +467,7 @@ class group(Signature):
return repr(self.tasks)
-Signature.register_type
+@Signature.register_type
class chord(Signature):
def __init__(self, header, body=None, task='celery.chord',
@@ -6,13 +6,6 @@ from celery.tests.case import Case
class test_compat_messaging_module(Case):
- def test_with_connection(self):
-
- def foo(**kwargs):
- pass
- self.assertTrue(messaging.with_connection(foo))
def test_get_consume_set(self):
conn = messaging.establish_connection()
messaging.get_consumer_set(conn).close()