diff --git a/dnet-ariadneplus-graphdb-publisher/src/main/java/eu/dnetlib/ariadneplus/reader/RunSPARQLQueryService.java b/dnet-ariadneplus-graphdb-publisher/src/main/java/eu/dnetlib/ariadneplus/reader/RunSPARQLQueryService.java
index 96222b4..511daf0 100644
--- a/dnet-ariadneplus-graphdb-publisher/src/main/java/eu/dnetlib/ariadneplus/reader/RunSPARQLQueryService.java
+++ b/dnet-ariadneplus-graphdb-publisher/src/main/java/eu/dnetlib/ariadneplus/reader/RunSPARQLQueryService.java
@@ -72,6 +72,7 @@ public class RunSPARQLQueryService {
 		final List<Integer> counter = Arrays.asList(new Integer(0));
 		recordIds.forEach(recordId -> {
 			int waitAmount=1;
+			int retryResult = 0;
 			int operationResult = executeQueryGraph(selectQueryTemplate, recordId, isCollection);
 			if (operationResult!=200) {
 				log.error(recordId + " error_code: "+ operationResult);
@@ -85,10 +86,10 @@ public class RunSPARQLQueryService {
 						} catch (InterruptedException ie) {
 							log.error(ie);
 						}
-						int retryResult = 0;
 						retryResult = executeQueryGraph(selectQueryTemplate, recordId, isCollection);
 						log.debug("retryResult: " + retryResult);
 					} while (retryResult!=200);
+					operationResult = retryResult;
 				}
 				if (operationResult!=200) {
 					int currentErrorsCount = errorCodesCount.get(0).intValue();