correctly set pipeline end date

hansva · Mar 14, 2024 · 3d24f21 · 3d24f21
1 parent c7f9702
commit 3d24f21
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/...rver/src/main/java/org/apache/hop/hopserver/logging/xp/PipelineLoggingExtensionPoint.java b/...rver/src/main/java/org/apache/hop/hopserver/logging/xp/PipelineLoggingExtensionPoint.java
@@ -115,8 +115,14 @@ public void run() {
       // Log pipeline Finished listener at the end
       pipeline.addExecutionFinishedListener(
           pipelineEngine -> {
-            timer.cancel();
-            logPipeline(log, pipeline, endpoint, Pipeline.STRING_FINISHED);
+            try {
+              timer.cancel();
+              pipeline.getExtensionDataMap().put(PIPELINE_END_DATE, new Date());
+              logPipeline(log, pipeline, endpoint, Pipeline.STRING_FINISHED);
+            } catch (Exception e) {
+              throw new RuntimeException(
+                  "Unable to do interval logging for Pipeline Log object", e);
+            }
           });
 
       pipeline.addExecutionStoppedListener(