(pool, errors)
| 3313 | errors_returned = [] |
| 3314 | |
| 3315 | def callback(pool, errors): |
| 3316 | errors_returned.extend(errors) |
| 3317 | set_keyspace_event.set() |
| 3318 | |
| 3319 | new_pool._set_keyspace_for_all_conns(self.keyspace, callback) |
| 3320 | set_keyspace_event.wait(self.cluster.connect_timeout) |