diff --git a/src/main/java/edu/ie3/datamodel/io/sink/CsvFileSink.java b/src/main/java/edu/ie3/datamodel/io/sink/CsvFileSink.java index bb31c1562..70b3569ef 100644 --- a/src/main/java/edu/ie3/datamodel/io/sink/CsvFileSink.java +++ b/src/main/java/edu/ie3/datamodel/io/sink/CsvFileSink.java @@ -326,6 +326,7 @@ private void write(C entity) { entityFieldData = processorProvider .handleEntity(entity) + .map(this::csvEntityFieldData) .orElseThrow( () -> new SinkException(