From 29c5a20fbedeaec5002cf096ff5d75db4af1aa0f Mon Sep 17 00:00:00 2001
From: nvolik <nikolay.volik@hotmail.com>
Date: Wed, 2 Aug 2023 10:46:41 +0200
Subject: [PATCH] Fix bug when allowed dataset skipped by pipelines, cause it
 is finihsed

---
 .../mapper/pipelines/PipelineProcessMapper.java            | 7 +++++++
 .../persistence/mapper/pipelines/PipelineProcessMapper.xml | 6 ++++++
 .../DefaultRegistryPipelinesHistoryTrackingService.java    | 7 +++++--
 3 files changed, 18 insertions(+), 2 deletions(-)

diff --git a/registry-persistence/src/main/java/org/gbif/registry/persistence/mapper/pipelines/PipelineProcessMapper.java b/registry-persistence/src/main/java/org/gbif/registry/persistence/mapper/pipelines/PipelineProcessMapper.java
index 2ae07805c..3d5b9cb17 100644
--- a/registry-persistence/src/main/java/org/gbif/registry/persistence/mapper/pipelines/PipelineProcessMapper.java
+++ b/registry-persistence/src/main/java/org/gbif/registry/persistence/mapper/pipelines/PipelineProcessMapper.java
@@ -175,4 +175,11 @@ long searchCount(
    * @param pipelineExecutionKey key of the process
    */
   void markPipelineExecutionIfFinished(@Param("pipelineExecutionKey") long pipelineExecutionKey);
+
+  /**
+   * When interpretation is allowed for failed identifiers, execution must have running status
+   *
+   * @param pipelineExecutionKey key of the process
+   */
+  void markPipelineExecutionAsRunning(@Param("pipelineExecutionKey") long pipelineExecutionKey);
 }
diff --git a/registry-persistence/src/main/resources/org/gbif/registry/persistence/mapper/pipelines/PipelineProcessMapper.xml b/registry-persistence/src/main/resources/org/gbif/registry/persistence/mapper/pipelines/PipelineProcessMapper.xml
index 0fe15c0f5..68a53f9c0 100644
--- a/registry-persistence/src/main/resources/org/gbif/registry/persistence/mapper/pipelines/PipelineProcessMapper.xml
+++ b/registry-persistence/src/main/resources/org/gbif/registry/persistence/mapper/pipelines/PipelineProcessMapper.xml
@@ -341,6 +341,12 @@
     WHERE finished = false;
   </update>
 
+  <update id="markPipelineExecutionAsRunning">
+    UPDATE pipeline_execution
+    SET finished = false
+    WHERE key = #{pipelineExecutionKey,jdbcType=BIGINT};
+  </update>
+
   <select id="getRunningPipelineProcessCount" resultType="Long">
     SELECT COUNT(1)
     FROM pipeline_execution pe
diff --git a/registry-pipelines/src/main/java/org/gbif/registry/pipelines/DefaultRegistryPipelinesHistoryTrackingService.java b/registry-pipelines/src/main/java/org/gbif/registry/pipelines/DefaultRegistryPipelinesHistoryTrackingService.java
index 9d22e20b6..6a479f610 100644
--- a/registry-pipelines/src/main/java/org/gbif/registry/pipelines/DefaultRegistryPipelinesHistoryTrackingService.java
+++ b/registry-pipelines/src/main/java/org/gbif/registry/pipelines/DefaultRegistryPipelinesHistoryTrackingService.java
@@ -768,7 +768,8 @@ public void allowAbsentIndentifiersCommon(UUID datasetKey, Integer attempt) {
           process.getExecutions().stream().max(Comparator.comparingLong(PipelineExecution::getKey));
 
       if (execution.isPresent()) {
-        Set<PipelineStep> steps = execution.get().getSteps();
+        PipelineExecution pipelineExecution = execution.get();
+        Set<PipelineStep> steps = pipelineExecution.getSteps();
         Optional<PipelineStep> identifierStep =
             steps.stream().filter(x -> x.getType() == StepType.VERBATIM_TO_IDENTIFIER).findAny();
 
@@ -791,6 +792,8 @@ public void allowAbsentIndentifiersCommon(UUID datasetKey, Integer attempt) {
                     mapper.updatePipelineStep(step);
                   });
 
+          mapper.markPipelineExecutionAsRunning(pipelineExecution.getKey());
+
           // Send message to interpretaton
           PipelinesVerbatimMessage message =
               objectMapper.readValue(pipelineStep.getMessage(), PipelinesVerbatimMessage.class);
@@ -808,7 +811,7 @@ public void allowAbsentIndentifiersCommon(UUID datasetKey, Integer attempt) {
               attempt);
         } else {
           LOG.warn(
-              "Execution ID - {} doesn't contain failed identifier step", execution.get().getKey());
+              "Execution ID - {} doesn't contain failed identifier step", pipelineExecution.getKey());
         }
       }
     } catch (IOException ex) {