@Test
public void checkExecutorHealthAlive() throws Exception {

  this.activeFlows.put(EXECUTION_ID_11, new Pair<>(
      new ExecutionReference(EXECUTION_ID_11, this.executor1), this.flow1));
  when(this.apiGateway.callWithExecutionId(this.executor1.getHost(), this.executor1.getPort(),
      ConnectorParams.PING_ACTION, null, null)).thenReturn(ImmutableMap.of(ConnectorParams
      .STATUS_PARAM, ConnectorParams.RESPONSE_ALIVE));
  this.executorHealthChecker.checkExecutorHealth();
  assertThat(this.flow1.getStatus()).isEqualTo(Status.RUNNING);
  verifyZeroInteractions(this.alerterHolder);
}