diff --git a/dhp-workflows/dhp-impact-indicators/src/main/resources/eu/dnetlib/dhp/oa/graph/impact_indicators/oozie_app/create_openaire_ranking_graph.py b/dhp-workflows/dhp-impact-indicators/src/main/resources/eu/dnetlib/dhp/oa/graph/impact_indicators/oozie_app/create_openaire_ranking_graph.py
index 182fd9309c..50d2cd99b8 100644
--- a/dhp-workflows/dhp-impact-indicators/src/main/resources/eu/dnetlib/dhp/oa/graph/impact_indicators/oozie_app/create_openaire_ranking_graph.py
+++ b/dhp-workflows/dhp-impact-indicators/src/main/resources/eu/dnetlib/dhp/oa/graph/impact_indicators/oozie_app/create_openaire_ranking_graph.py
@@ -132,8 +132,8 @@ cites_df  = spark.read.json(graph_folder + "/relation")\
                 & (F.col('dataInfo.invisible') == "false"))\
 				.drop('dataInfo.deletedbyinference').drop('dataInfo.invisible')\
 				.repartition(num_partitions, 'citing').drop('relClass')\
-				.withColumn('collected_lower', F.expr('transform(collectedfrom.value, x -> lower(x))'))\
-				.drop('collectedfrom.value')\
+				.withColumn('collected_lower', F.expr('transform(value, x -> lower(x))'))\
+				.drop('value')\
 				.where(
 					(F.array_contains(F.col('collected_lower'), "opencitations"))
             | 		(F.array_contains(F.col('collected_lower'), "crossref"))