From dcfcfa6c7fdf8c45a755bb601439ee7fe667076f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jan=20Ko=C5=BEusznik?= <jan@kozusznik.cz> Date: Wed, 31 Oct 2018 15:08:46 +0100 Subject: [PATCH] code: delete jobs --- .../fiji/haas_java_client/TestDeleteJobs.java | 39 +++++++++++++++++++ 1 file changed, 39 insertions(+) create mode 100644 haas-java-client/src/test/java/cz/it4i/fiji/haas_java_client/TestDeleteJobs.java diff --git a/haas-java-client/src/test/java/cz/it4i/fiji/haas_java_client/TestDeleteJobs.java b/haas-java-client/src/test/java/cz/it4i/fiji/haas_java_client/TestDeleteJobs.java new file mode 100644 index 00000000..191c921f --- /dev/null +++ b/haas-java-client/src/test/java/cz/it4i/fiji/haas_java_client/TestDeleteJobs.java @@ -0,0 +1,39 @@ +package cz.it4i.fiji.haas_java_client; + +import java.util.Arrays; +import java.util.stream.LongStream; + +import javax.xml.ws.WebServiceException; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +public class TestDeleteJobs { + + private final static Logger log = LoggerFactory.getLogger( + cz.it4i.fiji.haas_java_client.TestDeleteJobs.class); + + public static void main(String[] args) { + + Iterable<Long> iter = null; + if (args[0].contains(",")) { + iter =() -> Arrays.asList(args[0].split(",")).stream().map(Long::parseLong).iterator(); + } else { + long first = Integer.parseInt(args[0]); + long last = args.length > 1 ? Integer.parseInt(args[1]) : first; + iter =() -> LongStream.range(first, last + 1).iterator(); + } + HaaSClient client = new HaaSClient(SettingsProvider.getSettings( "OPEN-12-20", TestingConstants.CONFIGURATION_FILE_NAME)); + for ( long i : iter ) { + try { + JobInfo ji = client.obtainJobInfo(i); + + log.info("Delete job: " + i + " with state: " + ji.getState()); + client.deleteJob(i); + } + catch (WebServiceException e) { + log.info("job = " + i + " was already deleted"); + } + } + } +} -- GitLab