@Test(expected = IllegalArgumentException.class)
public void test_get_queue_name_unknown_stage() {

    new PipelineHelper(new PropertiesProvider(new HashMap<String, String>() {{
                put("stages", "SCAN,INDEX");}})).getQueueNameFor(DatashareCli.Stage.NLP);
}