From 86fe886c1ac305da1af29e2ea464a1166c0f3eb8 Mon Sep 17 00:00:00 2001
From: "miriam.baglioni" <miriam.baglioni@isti.cnr.it>
Date: Mon, 15 May 2023 11:20:51 +0200
Subject: [PATCH] removed the inverse of the Citing relation

---
 .../opencitations/CreateActionSetSparkJob.java            | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/actionmanager/opencitations/CreateActionSetSparkJob.java b/dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/actionmanager/opencitations/CreateActionSetSparkJob.java
index 61bc3fbca..4c658e52f 100644
--- a/dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/actionmanager/opencitations/CreateActionSetSparkJob.java
+++ b/dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/actionmanager/opencitations/CreateActionSetSparkJob.java
@@ -114,10 +114,10 @@ public class CreateActionSetSparkJob implements Serializable {
 
 		if (!citing.equals(cited)) {
 			relationList
-				.addAll(
-					getRelations(
+				.add(
+					getRelation(
 						citing,
-						cited));
+						cited, ModelConstants.CITES));
 
 			if (duplicate && value.getCiting().endsWith(".refs")) {
 				citing = ID_PREFIX + IdentifierFactory
@@ -125,7 +125,7 @@ public class CreateActionSetSparkJob implements Serializable {
 						CleaningFunctions
 							.normalizePidValue(
 								"doi", value.getCiting().substring(0, value.getCiting().indexOf(".refs"))));
-				relationList.addAll(getRelations(citing, cited));
+				relationList.add(getRelation(citing, cited, ModelConstants.CITES));
 			}
 		}