Merge pull request #6047 from FlorentinD/fix-relationshipFilter-progressLogging-21

Use the inputSource for updating the progress

Author: FlorentinD

subgraph-filtering/src/main/java/org/neo4j/gds/beta/filter/RelationshipsFilter.java

@@ -242,8 +242,8 @@ private RelationshipFilterTask(
 
         @Override
         public void run() {
-            partition.consume(node -> {
-                var neoSource = outputNodes.toOriginalNodeId(node);
+            partition.consume(outputSource -> {
+                var neoSource = outputNodes.toOriginalNodeId(outputSource);
                 var inputSource = inputNodes.toMappedNodeId(neoSource);
 
                 relationshipIterator.forEachRelationship(inputSource, (source, target, properties) -> {
@@ -268,7 +268,7 @@ public void run() {
                     return true;
                 });
 
-                progressTracker.logProgress(relationshipIterator.degree(node));
+                progressTracker.logProgress(relationshipIterator.degree(inputSource));
             });
         }
     }