docs: public void endJob(String targetCluster) throws ExecutionException {
          getConnection(targetCluster).setJobInProgress(false);
          logger.info("a new job has been finished in cluster [" + targetCluster + "]");
      }