docs: public boolean isPeggedToMe(String workUnitId)
     {
         ObjectNode zkWorkData = cluster.allWorkUnits.get(workUnitId);
         if (zkWorkData == null || zkWorkData.size() == 0) {
             cluster.workUnitsPeggedToMe.remove(workUnitId);
             return false;
         }
  
       try {
           JsonNode pegged = zkWorkData.get(cluster.name);
           final boolean isPegged = (pegged != null) && pegged.asText().equals(cluster.myNodeID);
  
           if (isPegged) {
               cluster.workUnitsPeggedToMe.add(workUnitId);
           } else {
               cluster.workUnitsPeggedToMe.remove(workUnitId);
           }
           return isPegged;
       } catch (Exception e) {
           LOG.error(String.format("Error parsing mapping for %s: %s", workUnitId, zkWorkData), e);
           return false;
       }
     }