diff --git a/dhp-workflows/dhp-enrichment/src/main/java/eu/dnetlib/dhp/projecttoresult/SparkResultToProjectThroughSemRelJob.java b/dhp-workflows/dhp-enrichment/src/main/java/eu/dnetlib/dhp/projecttoresult/SparkResultToProjectThroughSemRelJob.java
index 1ec521af1..a5868ffbd 100644
--- a/dhp-workflows/dhp-enrichment/src/main/java/eu/dnetlib/dhp/projecttoresult/SparkResultToProjectThroughSemRelJob.java
+++ b/dhp-workflows/dhp-enrichment/src/main/java/eu/dnetlib/dhp/projecttoresult/SparkResultToProjectThroughSemRelJob.java
@@ -107,30 +107,17 @@ public class SparkResultToProjectThroughSemRelJob {
 			potentialUpdate
 				.getProjectSet()
 				.forEach(
-					projectId -> {
-						newRelations
-							.add(
-								getRelation(
-									resId,
-									projectId,
-									ModelConstants.IS_PRODUCED_BY,
-									ModelConstants.RESULT_PROJECT,
-									ModelConstants.OUTCOME,
-									PROPAGATION_DATA_INFO_TYPE,
-									PROPAGATION_RELATION_RESULT_PROJECT_SEM_REL_CLASS_ID,
-									PROPAGATION_RELATION_RESULT_PROJECT_SEM_REL_CLASS_NAME));
-						newRelations
-							.add(
-								getRelation(
-									projectId,
-									resId,
-									ModelConstants.PRODUCES,
-									ModelConstants.RESULT_PROJECT,
-									ModelConstants.OUTCOME,
-									PROPAGATION_DATA_INFO_TYPE,
-									PROPAGATION_RELATION_RESULT_PROJECT_SEM_REL_CLASS_ID,
-									PROPAGATION_RELATION_RESULT_PROJECT_SEM_REL_CLASS_NAME));
-					});
+					projectId -> newRelations
+						.add(
+							getRelation(
+								projectId,
+								resId,
+								ModelConstants.PRODUCES,
+								ModelConstants.RESULT_PROJECT,
+								ModelConstants.OUTCOME,
+								PROPAGATION_DATA_INFO_TYPE,
+								PROPAGATION_RELATION_RESULT_PROJECT_SEM_REL_CLASS_ID,
+								PROPAGATION_RELATION_RESULT_PROJECT_SEM_REL_CLASS_NAME)));
 			return newRelations.iterator();
 		};
 	}
diff --git a/dhp-workflows/dhp-enrichment/src/main/java/eu/dnetlib/dhp/resulttoorganizationfrominstrepo/SparkResultToOrganizationFromIstRepoJob.java b/dhp-workflows/dhp-enrichment/src/main/java/eu/dnetlib/dhp/resulttoorganizationfrominstrepo/SparkResultToOrganizationFromIstRepoJob.java
index 0757ebccd..55bc73e83 100644
--- a/dhp-workflows/dhp-enrichment/src/main/java/eu/dnetlib/dhp/resulttoorganizationfrominstrepo/SparkResultToOrganizationFromIstRepoJob.java
+++ b/dhp-workflows/dhp-enrichment/src/main/java/eu/dnetlib/dhp/resulttoorganizationfrominstrepo/SparkResultToOrganizationFromIstRepoJob.java
@@ -139,10 +139,12 @@ public class SparkResultToOrganizationFromIstRepoJob {
 			organizations
 				.forEach(
 					orgId -> newRelations
-						.addAll(
-							getOrganizationRelationPair(
-								orgId,
-								resultId,
+						.add(
+							getRelation(
+								resultId, orgId,
+								ModelConstants.HAS_AUTHOR_INSTITUTION,
+								ModelConstants.RESULT_ORGANIZATION,
+								ModelConstants.AFFILIATION, PROPAGATION_DATA_INFO_TYPE,
 								PROPAGATION_RELATION_RESULT_ORGANIZATION_INST_REPO_CLASS_ID,
 								PROPAGATION_RELATION_RESULT_ORGANIZATION_INST_REPO_CLASS_NAME))
 
diff --git a/dhp-workflows/dhp-enrichment/src/main/java/eu/dnetlib/dhp/resulttoorganizationfromsemrel/SparkResultToOrganizationFromSemRel.java b/dhp-workflows/dhp-enrichment/src/main/java/eu/dnetlib/dhp/resulttoorganizationfromsemrel/SparkResultToOrganizationFromSemRel.java
index cfc69a8f0..91d28ef34 100644
--- a/dhp-workflows/dhp-enrichment/src/main/java/eu/dnetlib/dhp/resulttoorganizationfromsemrel/SparkResultToOrganizationFromSemRel.java
+++ b/dhp-workflows/dhp-enrichment/src/main/java/eu/dnetlib/dhp/resulttoorganizationfromsemrel/SparkResultToOrganizationFromSemRel.java
@@ -211,19 +211,6 @@ public class SparkResultToOrganizationFromSemRel implements Serializable {
 			.groupByKey((MapFunction<Relation, String>) r -> r.getSource() + r.getTarget(), Encoders.STRING())
 			.mapGroups(
 				(MapGroupsFunction<String, Relation, Relation>) (k, it) -> it.next(), Encoders.bean(Relation.class))
-			.flatMap(
-				(FlatMapFunction<Relation, Relation>) r -> Arrays
-					.asList(
-						r, getRelation(
-							r.getTarget(), r.getSource(), ModelConstants.IS_AUTHOR_INSTITUTION_OF,
-							ModelConstants.RESULT_ORGANIZATION,
-							ModelConstants.AFFILIATION,
-							PROPAGATION_DATA_INFO_TYPE,
-							PROPAGATION_RELATION_RESULT_ORGANIZATION_SEM_REL_CLASS_ID,
-							PROPAGATION_RELATION_RESULT_ORGANIZATION_SEM_REL_CLASS_NAME))
-					.iterator()
-
-				, Encoders.bean(Relation.class))
 			.write()
 
 			.mode(SaveMode.Append)