From 2aafbc8506353f6e32ce8f3a9646c457d6e773df Mon Sep 17 00:00:00 2001
From: Enrico Ottonello <enrico.ottonello@isti.cnr.it>
Date: Sat, 10 Oct 2020 01:03:41 +0200
Subject: [PATCH] fix loop condition

---
 .../eu/dnetlib/ariadneplus/reader/RunSPARQLQueryService.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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();