gCubeSystem
/
ecological-engine-smart-executor
15
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/data-analysis/EcologicalEngineSmartExecutor@122706 82a268e6-3cf1-43bd-a215-b396298e98cf

This commit is contained in:
Gianpaolo Coro 2016-02-01 22:08:46 +00:00
parent b3c9a340d2
commit ff84a0f9d3
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/org/gcube/dataanalysis/executor/job/management/QueueJobManager.java
View File

@ -193,13 +193,15 @@ public class QueueJobManager {
findNodes(scope);
}
public QueueJobManager(String scope, int numberOfNodes) throws Exception {
public QueueJobManager(String scope, int numberOfNodes, String session) throws Exception {
init(scope, numberOfNodes);
this.session = session;
}
public QueueJobManager(String scope, int numberOfNodes, List<String> eprs) throws Exception {
public QueueJobManager(String scope, int numberOfNodes, List<String> eprs, String session) throws Exception {
init(scope, numberOfNodes);
this.eprs = eprs;
this.session = session;
}
private void setGlobalVars(String serviceClass, String serviceName, String owner, String localDir, String remoteDir, String outputDir, String script, List<String> arguments, String configuration, boolean deletefiles) {
@ -224,7 +226,8 @@ public class QueueJobManager {
/*generic-worker
* int div = elements / (maxNumberOfMessages); int rest = elements % (maxNumberOfMessages); if (rest > 0) div++; if (div == 0) { div = 1; }
*/
session = (("" + UUID.randomUUID()).replace("-", "") + Math.random()).replace(".", "");
if (session == null || session.length()==0)
session = (("" + UUID.randomUUID()).replace("-", "") + Math.random()).replace(".", "");
int[] chunkSizes = null;
//up to 1120 species we don't make stages
if (elements>maxNumberOfStages)