@Test
public void should_execute_statement_with_consistency_option() throws Exception {

    //Given
    String statement = "@consistency=THREE\n" +
            "SELECT * FROM zeppelin.artists LIMIT 1;";
    //When
    final InterpreterResult actual = interpreter.interpret(statement, intrContext);
    //Then
    assertThat(actual.code()).isEqualTo(Code.ERROR);
    assertThat(actual.message())
            .contains("Not enough replicas available for query at consistency THREE (3 required but only 1 alive)");
}