docs: protected void claimWorkPeggedToMe(String workUnit)
         throws InterruptedException {
         String path = cluster.workUnitClaimPath(workUnit);
  
         while (true) {
             if (ZKUtils.createEphemeral(cluster.zk, path, cluster.myNodeID) || cluster.znodeIsMe(path)) {
                 cluster.startWork(workUnit);
                 return;
             }
             LOG.warn("Attempting to establish ownership of {}. Retrying in one second...", workUnit);
             Thread.sleep(1000);
         }
     }