docs: private void checkContinueWork() throws InterruptedException {
          boolean working = arbitrateEventService.mainStemEvent().check(pipelineId);
          if (!working) {
              logger.warn("mainstem is not run in this node");
              stopup(true);
          }
  
      }