@Test
public void testSwitchesRunners() throws Exception {

  when(runnerId.apply(runState)).thenReturn("id-1", "id-2");
  flyteRunner.createExecution(runState, EXEC_NAME, execConf, ANNOTATIONS);
  flyteRunner.createExecution(runState, EXEC_NAME, execConf, ANNOTATIONS);
  assertThatCreateCountersContains("id-1", "id-2");
}