docs: public void claimWork() throws InterruptedException {
          if (state.get() == NodeState.Started && !waitInProgress.get() && connected.get()) {
              balancingPolicy.claimWork();
          }
      }