Browse Source

Tests passing again

Ask Solem 14 năm trước cách đây
mục cha
commit
57dac938f5

+ 2 - 1
celery/tests/test_backends/test_amqp.py

@@ -4,6 +4,7 @@ import sys
 from datetime import timedelta
 from datetime import timedelta
 from Queue import Empty, Queue
 from Queue import Empty, Queue
 
 
+from celery import current_app
 from celery import states
 from celery import states
 from celery.app import app_or_default
 from celery.app import app_or_default
 from celery.backends.amqp import AMQPBackend
 from celery.backends.amqp import AMQPBackend
@@ -202,7 +203,7 @@ class test_AMQPBackend(unittest.TestCase):
                 pass
                 pass
 
 
         b = self.create_backend()
         b = self.create_backend()
-        conn = b.pool.acquire(block=False)
+        conn = current_app.pool.acquire(block=False)
         channel = conn.channel()
         channel = conn.channel()
         try:
         try:
             binding = b._create_binding(gen_unique_id())
             binding = b._create_binding(gen_unique_id())