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