@Test(expected = ExecutorManagerException.class)
public void testDuplicateQueuedFlows() throws Exception {

  final ExecutorManager manager = createMultiExecutorManagerInstance();
  final ExecutableFlow flow1 = TestUtils.createTestExecutableFlow("exectest1", "exec1");
  flow1.getExecutionOptions().setConcurrentOption(
      ExecutionOptions.CONCURRENT_OPTION_SKIP);
  final User testUser = TestUtils.getTestUser();
  manager.submitExecutableFlow(flow1, testUser.getUserId());
  manager.submitExecutableFlow(flow1, testUser.getUserId());
}