diff --git a/dnet-ariadneplus/src/main/java/eu/dnetlib/ariadneplus/workflows/nodes/EnrichGraphDBContentJobNode.java b/dnet-ariadneplus/src/main/java/eu/dnetlib/ariadneplus/workflows/nodes/EnrichGraphDBContentJobNode.java
index 0e99fc7..4f6feba 100644
--- a/dnet-ariadneplus/src/main/java/eu/dnetlib/ariadneplus/workflows/nodes/EnrichGraphDBContentJobNode.java
+++ b/dnet-ariadneplus/src/main/java/eu/dnetlib/ariadneplus/workflows/nodes/EnrichGraphDBContentJobNode.java
@@ -38,11 +38,6 @@ public class EnrichGraphDBContentJobNode extends AsyncJobNode {
 
 	private static final Log log = LogFactory.getLog(EnrichGraphDBContentJobNode.class);
 
-	private String eprParam;
-
-	@Autowired
-	private ResultSetClient resultSetClient;
-
 	private String sparqlUpdateQuery;
 	private String publisherEndpoint;
 	private String datasourceInterface;
@@ -117,36 +112,14 @@ public class EnrichGraphDBContentJobNode extends AsyncJobNode {
 		this.publisherEndpoint = publisherEndpoint;
 	}
 
-	public ResultSetClient getResultSetClient() {
-		return resultSetClient;
-	}
-
-	public void setResultSetClient(final ResultSetClient resultSetClient) {
-		this.resultSetClient = resultSetClient;
-	}
-
-	public String getEprParam() {
-		return eprParam;
-	}
-
-	public void setEprParam(String eprParam) {
-		this.eprParam = eprParam;
-	}
-	
 	public String getDatasourceInterface() {
 		return datasourceInterface;
 	}
 
-	
 	public void setDatasourceInterface(String datasourceInterface) {
 		this.datasourceInterface = datasourceInterface;
 	}
 
-	@Override
-	protected void beforeStart(Token token) {
-		token.setProgressProvider(new ResultsetProgressProvider(token.getEnv().getAttribute(getEprParam(), ResultSet.class), this.resultSetClient));
-	}
-
 	public String getDatasource() {
 		return datasource;
 	}
diff --git a/dnet-ariadneplus/src/main/java/eu/dnetlib/ariadneplus/workflows/nodes/IndexOnESJobNode.java b/dnet-ariadneplus/src/main/java/eu/dnetlib/ariadneplus/workflows/nodes/IndexOnESJobNode.java
index 8bdfdd2..fba0b2e 100644
--- a/dnet-ariadneplus/src/main/java/eu/dnetlib/ariadneplus/workflows/nodes/IndexOnESJobNode.java
+++ b/dnet-ariadneplus/src/main/java/eu/dnetlib/ariadneplus/workflows/nodes/IndexOnESJobNode.java
@@ -37,11 +37,6 @@ public class IndexOnESJobNode extends AsyncJobNode {
 
 	private static final Log log = LogFactory.getLog(IndexOnESJobNode.class);
 
-	private String eprParam;
-
-	@Autowired
-	private ResultSetClient resultSetClient;
-
 	private String publisherEndpoint;
 	private String datasourceInterface;
 	private String datasource;
@@ -122,36 +117,14 @@ public class IndexOnESJobNode extends AsyncJobNode {
 		this.publisherEndpoint = publisherEndpoint;
 	}
 
-	public ResultSetClient getResultSetClient() {
-		return resultSetClient;
-	}
-
-	public void setResultSetClient(final ResultSetClient resultSetClient) {
-		this.resultSetClient = resultSetClient;
-	}
-
-	public String getEprParam() {
-		return eprParam;
-	}
-
-	public void setEprParam(String eprParam) {
-		this.eprParam = eprParam;
-	}
-	
 	public String getDatasourceInterface() {
 		return datasourceInterface;
 	}
 
-	
 	public void setDatasourceInterface(String datasourceInterface) {
 		this.datasourceInterface = datasourceInterface;
 	}
 
-	@Override
-	protected void beforeStart(Token token) {
-		token.setProgressProvider(new ResultsetProgressProvider(token.getEnv().getAttribute(getEprParam(), ResultSet.class), this.resultSetClient));
-	}
-
 	public String getDatasource() {
 		return datasource;
 	}