Decrement worker metric when its execution returns with an error. (#495)

topfreegames · Jul 20, 2022 · 9278846 · 9278846
1 parent 9b0851b
commit 9278846
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/internal/core/services/workers_manager/workers_manager.go b/internal/core/services/workers_manager/workers_manager.go
@@ -155,6 +155,7 @@ func (w *WorkersManager) startWorker(ctx context.Context, name string, wkr worke
 	go func() {
 		err := wkr.Start(ctx)
 		if err != nil {
+			reportWorkerStop(name, w.builder.ComponentName)
 			w.logger.
 				With(zap.Error(err)).
 				With(zap.String("scheduler", name)).