update pipeline_recovering metric on recovery (#1932)

ConduitIO · Oct 25, 2024 · 552a613 · 552a613
1 parent 5a7a56a
commit 552a613
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/lifecycle/service.go b/pkg/lifecycle/service.go
@@ -821,6 +821,7 @@ func (s *Service) runPipeline(ctx context.Context, rp *runnablePipeline) error {
 // recoverPipeline attempts to recover a pipeline that has stopped running.
 func (s *Service) recoverPipeline(ctx context.Context, rp *runnablePipeline) error {
 	s.logger.Trace(ctx).Str(log.PipelineIDField, rp.pipeline.ID).Msg("recovering pipeline")
+	measure.PipelineRecoveringCount.WithValues(rp.pipeline.Config.Name).Inc()
 
 	err := s.pipelines.UpdateStatus(ctx, rp.pipeline.ID, pipeline.StatusRecovering, "")
 	if err != nil {