@Test
public void testCreateExecutionForAlreadyExistsException() throws FlyteRunner.CreateExecutionException {

  doThrow(new StatusRuntimeException(Status.ALREADY_EXISTS))
      .when(flyteAdminClient).createExecution(any(), any(), any(), any(), any(), any(), any());
  var runnerId = flyteRunner.createExecution(RUN_STATE, "exec", FLYTE_EXEC_CONF, ANNOTATIONS);
  assertThat(runnerId, is(RUNNER_ID));
  verify(flyteAdminClient).createExecution(
      LAUNCH_PLAN_IDENTIFIER.project(), LAUNCH_PLAN_IDENTIFIER.domain(), "exec",
      toProto(LAUNCH_PLAN_IDENTIFIER), SCHEDULED, ANNOTATIONS, RUN_STATE.workflowInstance().parameter());
}