@Test
public void testFlowStatusWithFetchExecutableFlows() throws Exception {

  final ExecutableFlow flow = submitNewFlow("exectest1", "exec1",
      System.currentTimeMillis(), ExecutionOptions.DEFAULT_FLOW_PRIORITY);
  int execId = flow.getExecutionId();
  makeFlowStatusInconsistent(execId, Status.FAILED_FINISHING);
  final ExecutableFlow fetchedFlow = this.executionFlowDao.fetchExecutableFlow(execId);
  assertThat(fetchedFlow.getStatus()).isEqualTo(Status.FAILED_FINISHING);
}