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