def test_describe_errors_unlock_describe_ring(self):
        num_nodes = 5
        pool_size = 10
        with self.cluster_and_pool(num_nodes=num_nodes, pool_size=pool_size):
            conn = list(self.pool.connectors)[0]

            def exec_raises(x, y=None):
                import time
                time.sleep(1)
                raise ValueError("Bad things.")

            try:
                conn.execute = exec_raises
                x = conn.my_describe_ring()
                self.assertTrue(self.pool.describing_ring)
                yield x
                self.assertTrue(False, "Expected exception.")
            except __HOLE__, e:
                self.assertFalse(self.pool.describing_ring)
dataset/ETHPy150Open driftx/Telephus/test/test_cassandraclusterpool.py/CassandraClusterPoolTest.test_describe_errors_unlock_describe_ring