Skip to content

Commit 552a613

Browse files
authored
update pipeline_recovering metric on recovery (#1932)
1 parent 5a7a56a commit 552a613

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

pkg/lifecycle/service.go

+1
Original file line numberDiff line numberDiff line change
@@ -821,6 +821,7 @@ func (s *Service) runPipeline(ctx context.Context, rp *runnablePipeline) error {
821821
// recoverPipeline attempts to recover a pipeline that has stopped running.
822822
func (s *Service) recoverPipeline(ctx context.Context, rp *runnablePipeline) error {
823823
s.logger.Trace(ctx).Str(log.PipelineIDField, rp.pipeline.ID).Msg("recovering pipeline")
824+
measure.PipelineRecoveringCount.WithValues(rp.pipeline.Config.Name).Inc()
824825

825826
err := s.pipelines.UpdateStatus(ctx, rp.pipeline.ID, pipeline.StatusRecovering, "")
826827
if err != nil {

0 commit comments

Comments
 (0)