fix suspend cancelation

hephbuild · Apr 16, 2024 · fdb20bb · fdb20bb
1 parent 3ec18ac
commit fdb20bb
Showing 1 changed file with 2 additions and 10 deletions.
diff --git a/worker2/worker.go b/worker2/worker.go
@@ -44,16 +44,8 @@ func (w *Worker) Run() {
 		w.exec.eventsCh <- EventSuspended{Execution: w.exec}
 
 		go func() {
-			select {
-			case <-ctx.Done():
-				w.exec.eventsCh <- EventCompleted{
-					Execution: w.exec,
-					Output:    w.exec.outStore.Get(),
-					Error:     ctx.Err(),
-				}
-			case <-w.exec.resumeCh:
-				w.queue()
-			}
+			<-w.exec.resumeCh
+			w.queue()
 		}()
 	} else {
 		w.exec.eventsCh <- EventCompleted{