

def _assert_reads_succeed(self, session, keyspace, consistency_levels, expected_reader=3):
    for cl in consistency_levels:
        self.coordinator_stats.reset_counts()
        try:
            self._query(session, keyspace, 1, cl)
            for i in range(3):
                if (i == expected_reader):
                    self.coordinator_stats.assert_query_count_equals(self, i, 1)
                else:
                    self.coordinator_stats.assert_query_count_equals(self, i, 0)
        except Exception as e:
            self._cl_failure(cl, e)

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