gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagManager.java
/**
   * Method to submit a {@link Dag} to the {@link DagManager}. The {@link DagManager} first persists the
   * submitted dag to the {@link DagStateStore} and then adds the dag to a {@link BlockingQueue} to be picked up
   * by one of the {@link DagManagerThread}s.
   */
Method to submit a  Dag to the  DagManager. The  DagManager first persists the
submitted dag to the  DagStateStore and then adds the dag to a  BlockingQueue to be picked up
by one of the  DagManagerThreads.
Method to submit a Dag to the DagManager . The DagManager first persists the submitted dag to the DagStateStore and then adds the dag to a BlockingQueue to be picked up by one of the DagManagerThreads .
synchronized void addDag(Dag<JobExecutionPlan> dag) throws IOException {
    this.dagStateStore.writeCheckpoint(dag);
    long flowExecutionId = DagManagerUtils.getFlowExecId(dag);
    int queueId = (int) (flowExecutionId % this.numThreads);
    if (!this.queue[queueId].offer(dag)) {
      throw new IOException("Could not add dag" + DagManagerUtils.generateDagId(dag) + "to queue");
    }
    submitEventsAndSetStatus(dag);
  }
synchronized void addDag ( Dag < JobExecutionPlan > dag ) throws IOException { this . dagStateStore . writeCheckpoint ( dag ) ; long flowExecutionId = DagManagerUtils . getFlowExecId ( dag ) ; int queueId = ( int ) ( flowExecutionId % this . numThreads ) ; if ( ! this . queue [ queueId ] . offer ( dag ) ) { throw new IOException ( "Could not add dag" + DagManagerUtils . generateDagId ( dag ) + "to queue" ) ; } submitEventsAndSetStatus ( dag ) ; }
Method to submit a {@link Dag} to the {@link DagManager}.
Method to submit a { @link Dag } to the { @link DagManager } .
//Persist the dag // Add the dag to the specific queue determined by flowExecutionId // Flow cancellation request has to be forwarded to the same DagManagerThread where the // flow create request was forwarded. This is because Azkaban Exec Id is stored in the DagNode of the // specific DagManagerThread queue