diff --git a/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/projecttoresult/SparkResultToProjectThroughSemRelJob.java b/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/projecttoresult/SparkResultToProjectThroughSemRelJob.java
index 1d99b3ec8d..1798aa67a0 100644
--- a/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/projecttoresult/SparkResultToProjectThroughSemRelJob.java
+++ b/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/projecttoresult/SparkResultToProjectThroughSemRelJob.java
@@ -48,11 +48,7 @@ public class SparkResultToProjectThroughSemRelJob {
         JavaRDD<Relation> relations = sc.sequenceFile(inputPath + "/relation", Text.class, Text.class)
                 .map(item -> new ObjectMapper().readValue(item._2().toString(), Relation.class)).cache();
 
-        JavaPairRDD<String, TypedRow> result_result = relations
-                .filter(r -> !r.getDataInfo().getDeletedbyinference())
-                .filter(r -> allowedsemrel.contains(r.getRelClass()) && RELATION_RESULTRESULT_REL_TYPE.equals(r.getRelType()))
-                .map(r -> new TypedRow().setSourceId(r.getSource()).setTargetId(r.getTarget()))
-                .mapToPair(toPair());
+        JavaPairRDD<String, TypedRow> result_result = getResultResultSemRel(allowedsemrel, relations);
 
         JavaPairRDD<String, TypedRow> result_project = relations
                 .filter(r -> !r.getDataInfo().getDeletedbyinference())
@@ -117,4 +113,6 @@ public class SparkResultToProjectThroughSemRelJob {
     }
 
 
+
+
 }