uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/WorkerHelixManager.java [168:175]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
      if (!isPipelineExisted(pipeline)) {
        setEmptyResourceConfig(pipeline);
        _helixAdmin.addResource(_helixClusterName, pipeline,
            IdealStateBuilder.buildCustomIdealStateFor(pipeline, String.valueOf(routeId), instances));
      } else {
        _helixAdmin.setResourceIdealState(_helixClusterName, pipeline,
            IdealStateBuilder.expandCustomIdealStateFor(_helixAdmin.getResourceIdealState(_helixClusterName, pipeline),
                pipeline, String.valueOf(routeId), instances, _conf.getMaxNumWorkersPerRoute()));
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/WorkerHelixManager.java [225:232]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        if (!isPipelineExisted(pipeline)) {
          setEmptyResourceConfig(pipeline);
          _helixAdmin.addResource(_helixClusterName, pipeline,
              IdealStateBuilder.buildCustomIdealStateFor(pipeline, String.valueOf(routeId), instances));
        } else {
          _helixAdmin.setResourceIdealState(_helixClusterName, pipeline,
              IdealStateBuilder.expandCustomIdealStateFor(_helixAdmin.getResourceIdealState(_helixClusterName, pipeline),
                  pipeline, String.valueOf(routeId), instances, _conf.getMaxNumWorkersPerRoute()));
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -