uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/WorkerHelixManager.java [173:183]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        _helixAdmin.setResourceIdealState(_helixClusterName, pipeline,
            IdealStateBuilder.expandCustomIdealStateFor(_helixAdmin.getResourceIdealState(_helixClusterName, pipeline),
                pipeline, String.valueOf(routeId), instances, _conf.getMaxNumWorkersPerRoute()));
      }
      TopicPartition route = new TopicPartition(pipeline, routeId);
      _routeToInstanceMap.putIfAbsent(route, new ArrayList<>());
      _routeToInstanceMap.get(route).addAll(instances);
      _availableWorkerList.removeAll(instances);
      controller.addWorkers(instances);
    } finally {
      _lock.unlock();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/WorkerHelixManager.java [241:252]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        _helixAdmin.setResourceIdealState(_helixClusterName, pipeline,
            IdealStateBuilder.expandCustomIdealStateFor(_helixAdmin.getResourceIdealState(_helixClusterName, pipeline),
                pipeline, String.valueOf(routeId), instances, _conf.getMaxNumWorkersPerRoute()));
      }

      TopicPartition route = new TopicPartition(pipeline, routeId);
      _routeToInstanceMap.putIfAbsent(route, new ArrayList<>());
      _routeToInstanceMap.get(route).addAll(instances);
      _availableWorkerList.removeAll(instances);
      controller.addWorkers(instances);
    } finally {
      _lock.unlock();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -