diff --git a/apps/bfd-pipeline/bfd-pipeline-app/src/main/java/gov/cms/bfd/pipeline/app/PipelineApplication.java b/apps/bfd-pipeline/bfd-pipeline-app/src/main/java/gov/cms/bfd/pipeline/app/PipelineApplication.java index 4bb6a61c4d..6693165fc9 100644 --- a/apps/bfd-pipeline/bfd-pipeline-app/src/main/java/gov/cms/bfd/pipeline/app/PipelineApplication.java +++ b/apps/bfd-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);