Use one transaction for inserting status and results.

gridsuite · Sep 20, 2023 · be94cd7 · be94cd7
1 parent fbdd8fc
commit be94cd7
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/...ridsuite/sensitivityanalysis/server/repositories/SensitivityAnalysisResultRepository.java b/...ridsuite/sensitivityanalysis/server/repositories/SensitivityAnalysisResultRepository.java
@@ -112,11 +112,11 @@ public void insertStatus(List<UUID> resultUuids, String status) {
     }
 
     @Transactional
-    public void insert(UUID resultUuid, SensitivityAnalysisResult result) {
+    public void insert(UUID resultUuid, SensitivityAnalysisResult result, String status) {
         Objects.requireNonNull(resultUuid);
-
         if (result != null) {
             analysisResultRepository.save(toAnalysisResultEntity(resultUuid, result));
+            globalStatusRepository.save(toStatusEntity(resultUuid, status));
         }
     }
 

diff --git a/...va/org/gridsuite/sensitivityanalysis/server/service/SensitivityAnalysisWorkerService.java b/...va/org/gridsuite/sensitivityanalysis/server/service/SensitivityAnalysisWorkerService.java
@@ -239,8 +239,7 @@ public Consumer<Message<String>> consumeRun() {
                 long nanoTime = System.nanoTime();
                 LOGGER.info("Just run in {}s", TimeUnit.NANOSECONDS.toSeconds(nanoTime - startTime.getAndSet(nanoTime)));
 
-                resultRepository.insert(resultContext.getResultUuid(), result);
-                resultRepository.insertStatus(List.of(resultContext.getResultUuid()), SensitivityAnalysisStatus.COMPLETED.name());
+                resultRepository.insert(resultContext.getResultUuid(), result, SensitivityAnalysisStatus.COMPLETED.name());
                 long finalNanoTime = System.nanoTime();
                 LOGGER.info("Stored in {}s", TimeUnit.NANOSECONDS.toSeconds(finalNanoTime - startTime.getAndSet(finalNanoTime)));