@Test
public void testProcessSucceed() throws Exception {

  final TriggerInstance triggerInstance = createTriggerInstance();
  this.processor.processSucceed(triggerInstance);
  this.submitFlowLatch.await(10L, TimeUnit.SECONDS);
  verify(this.executorManager).submitExecutableFlow(any(), anyString());
  this.updateExecIDLatch.await(10L, TimeUnit.SECONDS);
  verify(this.triggerInstLoader).updateAssociatedFlowExecId(triggerInstance);
}