You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Redis requirements list redis>=2.8.
Running a celery task with celery==3.1.17, kombu==3.0.35, and redis==2.8.0 installed:
Traceback (most recent call last):
File "<console>", line 1, in <module>
File "/usr/local/lib/python2.7/site-packages/celery/app/task.py", line 453, in delay
return self.apply_async(args, kwargs)
File "/usr/local/lib/python2.7/site-packages/celery/app/task.py", line 555, in apply_async
**dict(self._get_exec_options(), **options)
File "/usr/local/lib/python2.7/site-packages/celery/app/base.py", line 353, in send_task
reply_to=reply_to or self.oid, **options
File "/usr/local/lib/python2.7/site-packages/celery/app/amqp.py", line 305, in publish_task
**kwargs
File "/usr/local/lib/python2.7/site-packages/kombu/messaging.py", line 172, in publish
routing_key, mandatory, immediate, exchange, declare)
File "/usr/local/lib/python2.7/site-packages/kombu/connection.py", line 436, in _ensured
return fun(*args, **kwargs)
File "/usr/local/lib/python2.7/site-packages/kombu/messaging.py", line 177, in _publish
channel = self.channel
File "/usr/local/lib/python2.7/site-packages/kombu/messaging.py", line 194, in _get_channel
channel = self._channel = channel()
File "/usr/local/lib/python2.7/site-packages/kombu/utils/__init__.py", line 425, in __call__
value = self.__value__ = self.__contract__()
File "/usr/local/lib/python2.7/site-packages/kombu/messaging.py", line 209, in <lambda>
channel = ChannelPromise(lambda: connection.default_channel)
File "/usr/local/lib/python2.7/site-packages/kombu/connection.py", line 757, in default_channel
self.connection
File "/usr/local/lib/python2.7/site-packages/kombu/connection.py", line 742, in connection
self._connection = self._establish_connection()
File "/usr/local/lib/python2.7/site-packages/kombu/connection.py", line 697, in _establish_connection
conn = self.transport.establish_connection()
File "/usr/local/lib/python2.7/site-packages/kombu/transport/virtual/__init__.py", line 809, in establish_connection
self._avail_channels.append(self.create_channel(self))
File "/usr/local/lib/python2.7/site-packages/kombu/transport/virtual/__init__.py", line 791, in create_channel
channel = self.Channel(connection)
File "/usr/local/lib/python2.7/site-packages/kombu/transport/redis.py", line 464, in __init__
self.client.info()
File "/usr/local/lib/python2.7/site-packages/kombu/utils/__init__.py", line 325, in __get__
value = obj.__dict__[self.__name__] = self.__get(obj)
File "/usr/local/lib/python2.7/site-packages/kombu/transport/redis.py", line 908, in client
return self._create_client(async=True)
File "/usr/local/lib/python2.7/site-packages/kombu/transport/redis.py", line 861, in _create_client
return self.AsyncClient(connection_pool=self.async_pool)
File "/usr/local/lib/python2.7/site-packages/kombu/transport/redis.py", line 882, in __init__
self.connection = self.connection_pool.get_connection('_')
File "/usr/local/lib/python2.7/site-packages/redis/connection.py", line 405, in get_connection
connection = self.make_connection()
File "/usr/local/lib/python2.7/site-packages/redis/connection.py", line 414, in make_connection
return self.connection_class(**self.connection_kwargs)
TypeError: __init__() got an unexpected keyword argument 'socket_connect_timeout'
Same problem occurs with redis==2.9.
Upgrading to redis==2.10 resolved the issue, and the task ran as expected.
The text was updated successfully, but these errors were encountered:
ask
added a commit
that referenced
this issue
Apr 1, 2016
Redis requirements list
redis>=2.8
.Running a celery task with
celery==3.1.17
,kombu==3.0.35
, andredis==2.8.0
installed:Same problem occurs with
redis==2.9
.Upgrading to
redis==2.10
resolved the issue, and the task ran as expected.The text was updated successfully, but these errors were encountered: