close chan on jobrun goroutine instead

sonroyaalmerol · Nov 18, 2024 · a40bff6 · a40bff6
1 parent 27516d8
commit a40bff6
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/internal/backend/backup/jobrun.go b/internal/backend/backup/jobrun.go
@@ -136,7 +136,10 @@ func RunBackup(job *store.Job, storeInstance *store.Store, waitChan chan struct{
 	var task *store.Task
 	go func() {
 		taskC := <-taskChan
+		log.Printf("Task received: %s\n", taskC.UPID)
 		task = &taskC
+
+		close(taskChan)
 	}()
 
 	for {

diff --git a/internal/store/tasks.go b/internal/store/tasks.go
@@ -115,7 +115,6 @@ func (storeInstance *Store) GetMostRecentTask(ctx context.Context, job *Job) (ch
 
 	go func() {
 		defer watcher.Close()
-		defer close(returnChan)
 		for {
 			select {
 			case event := <-watcher.Events: