diff --git a/dhp-workflows/dhp-graph-mapper/src/main/java/eu/dnetlib/dhp/oa/graph/clean/country/CleanCountrySparkJob.java b/dhp-workflows/dhp-graph-mapper/src/main/java/eu/dnetlib/dhp/oa/graph/clean/country/CleanCountrySparkJob.java
index c150c63df..cd77f342e 100644
--- a/dhp-workflows/dhp-graph-mapper/src/main/java/eu/dnetlib/dhp/oa/graph/clean/country/CleanCountrySparkJob.java
+++ b/dhp-workflows/dhp-graph-mapper/src/main/java/eu/dnetlib/dhp/oa/graph/clean/country/CleanCountrySparkJob.java
@@ -117,7 +117,7 @@ public class CleanCountrySparkJob implements Serializable {
 					p -> p
 						.getQualifier()
 						.getClassid()
-						.equals(PidType.doi) && pidInParam(p.getValue(), verifyParam))) {
+						.equals(PidType.doi.toString()) && pidInParam(p.getValue(), verifyParam))) {
 				r
 					.setCountry(
 						r