From 94191c542f7c04df31c4c3d05b1f338d02852514 Mon Sep 17 00:00:00 2001
From: Gianpaolo Coro <gianpaolo.coro@isti.cnr.it>
Date: Mon, 1 Feb 2016 22:09:10 +0000
Subject: [PATCH] session management

git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/data-analysis/EcologicalEngineSmartExecutor@122707 82a268e6-3cf1-43bd-a215-b396298e98cf
---
 .../job/management/DistributedProcessingAgent.java       | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/src/main/java/org/gcube/dataanalysis/executor/job/management/DistributedProcessingAgent.java b/src/main/java/org/gcube/dataanalysis/executor/job/management/DistributedProcessingAgent.java
index 774f5a6..f23449e 100644
--- a/src/main/java/org/gcube/dataanalysis/executor/job/management/DistributedProcessingAgent.java
+++ b/src/main/java/org/gcube/dataanalysis/executor/job/management/DistributedProcessingAgent.java
@@ -36,6 +36,7 @@ public class DistributedProcessingAgent {
 	protected int leftSetNumberOfElements;
 	protected List<String> endpoints;
 	protected int subdivisiondiv;
+	protected String sessionID;
 	
 	protected static String defaultJobOutput = "execution.output";
 	protected static String defaultScriptFile = "script";
@@ -57,7 +58,8 @@ public class DistributedProcessingAgent {
 																int maxElementsPerJob, 
 																boolean forceReUploadofLibs,
 																int leftSetNumberOfElements,
-																int rightSetNumberOfElements
+																int rightSetNumberOfElements,
+																String sessionID
 																) {
 		this.stop = false;
 		this.deletefiles = true;
@@ -72,6 +74,7 @@ public class DistributedProcessingAgent {
 		this.pathToLib=pathToLibFolder;
 		this.modelName=modelName;
 		this.containerFolder=containerFolder;
+		this.sessionID = sessionID;
 	}
 
 	public void setLogger(Logger logger){
@@ -104,9 +107,9 @@ public class DistributedProcessingAgent {
 				
 				jobManager = new QueueJobManager(gscope, endpoints.size(), eprtList);
 				*/
-				jobManager = new QueueJobManager(gscope, endpoints.size(), endpoints);
+				jobManager = new QueueJobManager(gscope, endpoints.size(), endpoints,sessionID);
 			} else
-				jobManager = new QueueJobManager(gscope, 1);
+				jobManager = new QueueJobManager(gscope, 1,sessionID);
 
 			int numberOfResources = jobManager.getNumberOfNodes();
 			// we split along right dimension so if elements are less than nodes, we should reduce the number of nodes