From d8d4431f59f43362dea84d3010de577487190598 Mon Sep 17 00:00:00 2001
From: Son Roy Almerol <github@snry.me>
Date: Sun, 17 Nov 2024 20:13:50 -0500
Subject: [PATCH] use goroutine for taskChan receiver

---
 internal/backend/backup/jobrun.go | 11 +++++++++--
 internal/store/tasks.go           |  1 +
 2 files changed, 10 insertions(+), 2 deletions(-)

diff --git a/internal/backend/backup/jobrun.go b/internal/backend/backup/jobrun.go
index d32ba999..a08a6894 100644
--- a/internal/backend/backup/jobrun.go
+++ b/internal/backend/backup/jobrun.go
@@ -133,6 +133,12 @@ func RunBackup(job *store.Job, storeInstance *store.Store, waitChan chan struct{
 		return nil, fmt.Errorf("RunBackup: proxmox-backup-client start error (%s) -> %w", cmd.String(), err)
 	}
 
+	var task *store.Task
+	go func() {
+		taskC := <-taskChan
+		task = &taskC
+	}()
+
 	for {
 		line, err := logBuffer.ReadString('\n')
 		if err != nil && line != "" {
@@ -146,8 +152,9 @@ func RunBackup(job *store.Job, storeInstance *store.Store, waitChan chan struct{
 		time.Sleep(time.Millisecond * 100)
 	}
 
-	task, ok := <-taskChan
-	if !ok {
+	<-watchCtx.Done()
+
+	if task == nil {
 		return nil, fmt.Errorf("RunBackup: task not found -> %w", err)
 	}
 
diff --git a/internal/store/tasks.go b/internal/store/tasks.go
index ef184a3f..e740b6d7 100644
--- a/internal/store/tasks.go
+++ b/internal/store/tasks.go
@@ -135,6 +135,7 @@ func (storeInstance *Store) GetMostRecentTask(ctx context.Context, job *Job) (ch
 								return
 							}
 							returnChan <- *newTask
+							return
 						}
 					}
 				}