Ensure in-flight metrics are submitted when Pipeline is stopped

CMSgov · Jan 21, 2025 · 3231f1e · 3231f1e
1 parent edc6ed1
commit 3231f1e
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...pipeline/bfd-pipeline-app/src/main/java/gov/cms/bfd/pipeline/app/PipelineApplication.java b/...pipeline/bfd-pipeline-app/src/main/java/gov/cms/bfd/pipeline/app/PipelineApplication.java
@@ -347,6 +347,9 @@ private PipelineOutcome createJobsAndRunPipeline(
 
     PipelineOutcome pipelineOutcome = pipelineManager.awaitCompletion();
 
+    // Ensures that any CloudWatch metrics are published prior to the stop of the Pipeline
+    appMeters.close();
+
     if (pipelineManager.getError() != null) {
       throw new FatalAppException(
           "Pipeline job threw exception", pipelineManager.getError(), EXIT_CODE_JOB_FAILED);