From eef9e6b287f21090d3dc199a6490fa6ecaa7f924 Mon Sep 17 00:00:00 2001 From: Thibault Cohen <47721+titilambert@users.noreply.github.com> Date: Wed, 1 Jan 2025 23:43:53 -0500 Subject: [PATCH] Add metric when task fails (#625) --- internal/orchestrator/orchestrator.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/orchestrator/orchestrator.go b/internal/orchestrator/orchestrator.go index 2e846395..2b691ea7 100644 --- a/internal/orchestrator/orchestrator.go +++ b/internal/orchestrator/orchestrator.go @@ -429,6 +429,7 @@ func (o *Orchestrator) RunTask(ctx context.Context, st tasks.ScheduledTask) erro err := st.Task.Run(ctx, st, runner) if err != nil { runner.Logger(ctx).Error("task failed", zap.Error(err), zap.Duration("duration", time.Since(start))) + metric.GetRegistry().RecordTaskRun(st.Task.RepoID(), st.Task.PlanID(), st.Task.Type(), time.Since(start).Seconds(), "failed") } else { runner.Logger(ctx).Info("task finished", zap.Duration("duration", time.Since(start))) metric.GetRegistry().RecordTaskRun(st.Task.RepoID(), st.Task.PlanID(), st.Task.Type(), time.Since(start).Seconds(), "success")