@Test
public void checkExecutorHealthExecutorIdRemoved() throws Exception {

  this.activeFlows.put(EXECUTION_ID_11, new Pair<>(
      new ExecutionReference(EXECUTION_ID_11, null), this.flow1));
  when(this.loader.fetchExecutableFlow(EXECUTION_ID_11)).thenReturn(this.flow1);
  this.executorHealthChecker.checkExecutorHealth();
  verify(this.loader).updateExecutableFlow(this.flow1);
  assertThat(this.flow1.getStatus()).isEqualTo(Status.FAILED);
}