@Test
public void testToFlowTrigger() throws Exception {

  final NodeBeanLoader loader = new NodeBeanLoader();
  final NodeBean nodeBean = loader.load(ExecutionsTestUtil.getFlowFile(
      TRIGGER_FLOW_YML_TEST_DIR, TRIGGER_FLOW_YML_FILE));
  final FlowTrigger flowTrigger = loader.toFlowTrigger(nodeBean.getTrigger());
  validateFlowTrigger(flowTrigger, MAX_WAIT_MINS, CRON_EXPRESSION, 2);
  validateTriggerDependency(flowTrigger, TRIGGER_NAME_1, TRIGGER_TYPE, PARAMS_1);
  validateTriggerDependency(flowTrigger, TRIGGER_NAME_2, TRIGGER_TYPE, PARAMS_2);
}