@Test(dependsOnMethods = "testNewJobId") public void testNewMultiTaskId() { Assert.assertEquals(JobLauncherUtils.newMultiTaskId(this.jobId, 0), this.jobId.replace("job", "multitask") + "_0"); Assert.assertEquals(JobLauncherUtils.newMultiTaskId(this.jobId, 1), this.jobId.replace("job", "multitask") + "_1"); }
public static String newMultiTaskId(String jobId, int sequence) { return Id.MultiTask.create(Id.parse(jobId).get(Id.Parts.INSTANCE_NAME), sequence).toString(); }
JobLauncherUtils { public static String newMultiTaskId(String jobId, int sequence) { return Id.MultiTask.create(Id.parse(jobId).get(Id.Parts.INSTANCE_NAME), sequence).toString(); } }
JobLauncherUtils { public static String newMultiTaskId(String jobId, int sequence) { return Id.MultiTask.create(Id.parse(jobId).get(Id.Parts.INSTANCE_NAME), sequence).toString(); }  }
JobLauncherUtils { public static String newMultiTaskId(String jobId, int sequence) { return Id.MultiTask.create(Id.parse(jobId).get(Id.Parts.INSTANCE_NAME), sequence).toString(); }  static String newJobId(String jobName); static String newTaskId(String jobId, int sequence); static String newMultiTaskId(String jobId, int sequence); static List<WorkUnit> flattenWorkUnits(Collection<WorkUnit> workUnits); static void cleanStagingData(List<? extends State> states, Logger logger); static void cleanJobStagingData(State state, Logger logger); static void cleanTaskStagingData(State state, Logger logger); static void cleanTaskStagingData(State state, Logger logger, Closer closer,
      Map<String, ParallelRunner> parallelRunners); static void cleanUpOldJobData(State state, Logger logger, boolean stagingDirProvided, boolean outputDirProvided); }
JobLauncherUtils { public static String newMultiTaskId(String jobId, int sequence) { return Id.MultiTask.create(Id.parse(jobId).get(Id.Parts.INSTANCE_NAME), sequence).toString(); }  static String newJobId(String jobName); static String newTaskId(String jobId, int sequence); static String newMultiTaskId(String jobId, int sequence); static List<WorkUnit> flattenWorkUnits(Collection<WorkUnit> workUnits); static void cleanStagingData(List<? extends State> states, Logger logger); static void cleanJobStagingData(State state, Logger logger); static void cleanTaskStagingData(State state, Logger logger); static void cleanTaskStagingData(State state, Logger logger, Closer closer,
      Map<String, ParallelRunner> parallelRunners); static void cleanUpOldJobData(State state, Logger logger, boolean stagingDirProvided, boolean outputDirProvided);  }