diff --git a/src/main/scala/cognite/spark/v1/FileContentRelation.scala b/src/main/scala/cognite/spark/v1/FileContentRelation.scala index 0c2e110a3..465b62bf9 100644 --- a/src/main/scala/cognite/spark/v1/FileContentRelation.scala +++ b/src/main/scala/cognite/spark/v1/FileContentRelation.scala @@ -85,7 +85,8 @@ class FileContentRelation(config: RelationConfig, fileExternalId: String, inferS StreamIterator( Stream .eval(validUrl) - .flatMap(readUrlContentLines), + .flatMap(readUrlContentLines) + .evalTap(_ => IO.delay { itemsRead.inc() }), maxParallelism * 2, None )