Allow custon io loops for ConnectionPools

mher · Jan 1, 2014 · 402f7d3 · 402f7d3
1 parent c8697f4
commit 402f7d3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/tcelery/__init__.py b/tcelery/__init__.py
@@ -19,7 +19,7 @@ def setup_nonblocking_producer(celery_app=None, io_loop=None,
     io_loop = io_loop or ioloop.IOLoop.instance()
 
     NonBlockingTaskProducer.app = celery_app
-    NonBlockingTaskProducer.conn_pool = ConnectionPool(limit=limit)
+    NonBlockingTaskProducer.conn_pool = ConnectionPool(limit, io_loop)
     NonBlockingTaskProducer.result_cls = result_cls
     if celery_app.conf['BROKER_URL'] and celery_app.conf['BROKER_URL'].startswith('amqp'):
         celery.app.amqp.AMQP.producer_cls = NonBlockingTaskProducer