@Test
public void testTransitionRunningToRunningNoEventEmit() throws Exception {

  when(flyteAdminClient.getExecution("flyte-test", "testing", "execution-name")).thenReturn(
      ExecutionOuterClass.Execution
          .newBuilder()
          .setClosure(ExecutionOuterClass.ExecutionClosure.newBuilder()
              .setPhase(Execution.WorkflowExecution.Phase.RUNNING).build())
          .build());
  RunState state = runState(RunState.State.RUNNING);
  flyteRunner.poll(FLYTE_EXECUTION_ID, state);
  verify(stateManager,  never()).receive(Event.started(WORKFLOW_INSTANCE));
}