diff --git a/cassandra/pool.py b/cassandra/pool.py index a8e54d05..9c280366 100644 --- a/cassandra/pool.py +++ b/cassandra/pool.py @@ -509,6 +509,9 @@ class HostConnectionPool(object): conn.close() self.open_count -= 1 + for conn in self._trash: + conn.close() + def ensure_core_connections(self): if self.is_shutdown: return