Fixed passing server list to ConnectionPool. The servers are specified with "server_list" not "server" like they were for pycassa.connect

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,