do not merge: prime task manager cache

Signed-off-by: Sam Lucidi <[email protected]>
mansam · Jul 3, 2024 · a961df2 · a961df2
1 parent 2ba93e2
commit a961df2
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/cmd/main.go b/cmd/main.go
@@ -161,6 +161,10 @@ func main() {
 		Client: client,
 		DB:     db,
 	}
+	err = taskManager.Prime()
+	if err != nil {
+		return
+	}
 	taskManager.Run(context.Background())
 	//
 	// Reaper

diff --git a/task/manager.go b/task/manager.go
@@ -97,6 +97,13 @@ type Manager struct {
 	queue chan func()
 }
 
+// Prime the CR cache.
+func (m *Manager) Prime() (err error) {
+	m.cluster.Client = m.Client
+	err = m.cluster.Refresh()
+	return
+}
+
 // Run the manager.
 func (m *Manager) Run(ctx context.Context) {
 	m.queue = make(chan func(), 100)