fix(api,cdn): restart some goroutines (#5852)

Author: fsamin

engine/api/api.go

@@ -801,7 +801,7 @@ func (a *API) Serve(ctx context.Context) error {
 		func(ctx context.Context) {
 			services.Pings(ctx, a.mustDB, externalServices)
 		})
-	a.GoRoutines.Run(ctx, "workflow.Initialize",
+	a.GoRoutines.RunWithRestart(ctx, "workflow.Initialize",
 		func(ctx context.Context) {
 			workflow.SetMaxRuns(a.Config.Workflow.MaxRuns)
 			workflow.Initialize(ctx, a.DBConnectionFactory.GetDBMap(gorpmapping.Mapper), a.Cache, a.Config.URL.UI, a.Config.DefaultOS, a.Config.DefaultArch, a.Config.Log.StepMaxSize)

engine/api/status.go

@@ -279,7 +279,7 @@ func (api *API) computeMetrics(ctx context.Context) {
 		log.Error(ctx, "api.computeMetrics> unable to tag observability context: %v", err)
 	}
 
-	api.GoRoutines.Run(ctx, "api.computeMetrics", func(ctx context.Context) {
+	api.GoRoutines.RunWithRestart(ctx, "api.computeMetrics", func(ctx context.Context) {
 		tick := time.NewTicker(9 * time.Second).C
 		for {
 			select {

engine/cdn/cdn_metrics.go

@@ -65,7 +65,7 @@ func (s *Service) initMetrics(ctx context.Context) error {
 	itemUnitToDeleteView := telemetry.NewViewLast(s.Metrics.ItemUnitToDelete.Name(), s.Metrics.ItemUnitToDelete, []tag.Key{tagStorage, tagItemType})
 
 	if s.DBConnectionFactory != nil {
-		s.GoRoutines.Run(ctx, "cds-compute-metrics", func(ctx context.Context) {
+		s.GoRoutines.RunWithRestart(ctx, "cds-compute-metrics", func(ctx context.Context) {
 			s.ComputeMetrics(ctx)
 		})
 	}