Use one transaction for inserting status and results. (#35)

* Use one transaction for inserting status and results.
gridsuite · Sep 28, 2023 · 3807023 · 3807023
1 parent e50bb8b
commit 3807023
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
@@ -111,12 +111,12 @@ 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));
     }
 
     @Transactional

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)));