Skip to content

Commit 1cfd19f

Browse files
committed
Emit all datasets recalc in one consumer
Signed-off-by: Andrea Lamparelli <a.lamparelli95@gmail.com>
1 parent 4ece1b5 commit 1cfd19f

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

horreum-backend/src/main/java/io/hyperfoil/tools/horreum/svc/SchemaServiceImpl.java

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -876,10 +876,12 @@ private void emitLabelChanged(int labelId, int schemaId) {
876876
}
877877

878878
Log.infof("Queuing %s datasets for recalculation", datasetIds.size());
879-
for (var dataset : datasetIds) {
880-
Util.registerTxSynchronization(tm, txStatus -> mediator.queueDatasetEvents(
881-
new Dataset.EventNew((Integer) dataset[0], (Integer) dataset[1], 0, labelId, true)));
882-
}
879+
Util.registerTxSynchronization(tm, txStatus -> {
880+
for (var dataset : datasetIds) {
881+
mediator.queueDatasetEvents(
882+
new Dataset.EventNew((Integer) dataset[0], (Integer) dataset[1], 0, labelId, true));
883+
}
884+
});
883885
} catch (NoResultException nre) {
884886
Log.debugf("Could not find datasetId/testId to recalculate labels: %s", nre.getMessage());
885887
}

0 commit comments

Comments
 (0)