fix: start job history channel fetch before adding items

flanksource · Sep 23, 2024 · 964874d · 964874d
1 parent 9848b00
commit 964874d
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 1 deletion.
diff --git a/job/job.go b/job/job.go
@@ -39,7 +39,21 @@ const (
 	maxJitterDuration = time.Minute * 15
 )
 
-var EvictedJobs chan uuid.UUID
+var (
+	EvictedJobs       chan uuid.UUID
+	startedJobHistory = false
+)
+
+func StartJobHistoryEvictor(ctx context.Context) {
+	if !startedJobHistory {
+		if EvictedJobs == nil {
+			EvictedJobs = make(chan uuid.UUID, 1000)
+		}
+		go deleteEvictedJobs(ctx)
+		startedJobHistory = true
+	}
+
+}
 
 // deleteEvictedJobs deletes job_history rows from the DB every job.eviction.period(1m),
 // jobs send rows to be deleted by maintaining a circular buffer by status type

diff --git a/upstream/controllers.go b/upstream/controllers.go
@@ -9,6 +9,7 @@ import (
 	"github.com/flanksource/commons/logger"
 	"github.com/flanksource/duty/api"
 	"github.com/flanksource/duty/context"
+	"github.com/flanksource/duty/job"
 	"github.com/flanksource/duty/models"
 	"github.com/labstack/echo/v4"
 	"github.com/patrickmn/go-cache"
@@ -112,6 +113,7 @@ func addJobHistoryToRing(ctx context.Context, agentID string, histories []models
 	if ringManager == nil {
 		return
 	}
+	job.StartJobHistoryEvictor(ctx)
 
 	for _, history := range histories {
 		ringManager.Add(ctx, agentID, history)