diff --git a/cassandra/cluster.py b/cassandra/cluster.py index 1181c6f686..fdbdfb8d70 100644 --- a/cassandra/cluster.py +++ b/cassandra/cluster.py @@ -3439,7 +3439,7 @@ def pool_finished_setting_keyspace(pool, host_errors): errors[pool.host] = host_errors if not remaining_callbacks: - callback(host_errors) + callback(errors) for pool in tuple(self._pools.values()): pool._set_keyspace_for_all_conns(keyspace, pool_finished_setting_keyspace)