

def _assert_writes_fail(self, session, keyspace, consistency_levels):
    for cl in consistency_levels:
        self.coordinator_stats.reset_counts()
        try:
            self._insert(session, keyspace, 1, cl)
            self._cl_expected_failure(cl)
        except (Unavailable, WriteTimeout):
            pass

dataset/ETHPy150Open datastax/python-driver/tests/integration/long/test_consistency.py ConsistencyTests._assert_writes_fail/original