diff --git a/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/eosc/SelectEoscResultsJobStep1.java b/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/eosc/SelectEoscResultsJobStep1.java
index 8891448..dcf5cec 100644
--- a/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/eosc/SelectEoscResultsJobStep1.java
+++ b/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/eosc/SelectEoscResultsJobStep1.java
@@ -77,7 +77,11 @@ public class SelectEoscResultsJobStep1 implements Serializable {
 			.readPath(spark, inputPath, inputClazz)
 			.filter(
 				(FilterFunction<R>) r -> !r.getDataInfo().getDeletedbyinference() && !r.getDataInfo().getInvisible()
-					&& r.getContext().stream().anyMatch(c -> c.getId().equals("eosc")))
+					&& (r.getContext().stream().anyMatch(c -> c.getId().equals("eosc")) || r
+						.getCollectedfrom()
+						.stream()
+						.anyMatch(cf -> cf.getValue().equalsIgnoreCase("B2FIND"))))
+
 			.map(
 				(MapFunction<R, Result>) r -> (Result) ResultMapper
 					.map(r, communityMap),