worker: Fix continue downloading after encoding

pando85 · Jan 13, 2024 · 28a4d5d · 28a4d5d
1 parent e4a2e82
commit 28a4d5d
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/worker/task/encode.go b/worker/task/encode.go
@@ -151,6 +151,7 @@ func (E *EncodeWorker) resumeJobs() {
 		case taskEncode.LastState.IsDownloading():
 			E.AddDownloadJob(taskEncode.Task)
 		case taskEncode.LastState.IsEncoding():
+			atomic.AddUint32(&E.prefetchJobs, 1)
 			t := E.terminal.AddTask(fmt.Sprintf("cached: %s", taskEncode.Task.TaskEncode.Id.String()), DownloadJobStepType)
 			t.Done()
 			E.encodeChan <- taskEncode.Task