Browse Source

Merge branch 'jterrace/pycassa-1.4-fix'

Ask Solem 13 years ago
parent
commit
ee53d1ba4b
1 changed files with 1 additions and 1 deletions
  1. 1 1
      celery/backends/cassandra.py

+ 1 - 1
celery/backends/cassandra.py

@@ -106,7 +106,7 @@ class CassandraBackend(BaseDictBackend):
 
     def _get_column_family(self):
         if self._column_family is None:
-            conn = pycassa.ConnectionPool(self.keyspace, servers=self.servers,
+            conn = pycassa.ConnectionPool(self.keyspace, server_list=self.servers,
                                    **self.cassandra_options)
             self._column_family = \
               pycassa.ColumnFamily(conn, self.column_family,