From 1daebf83e6fa75c687b59aab1b031dcd217d2927 Mon Sep 17 00:00:00 2001
From: "copilot-swe-agent[bot]" <198982749+Copilot@users.noreply.github.com>
Date: Thu, 9 Oct 2025 22:08:35 +0000
Subject: [PATCH 1/2] Initial plan


From 087d3f1a2afbbe543a63987c60970dc5ad3575ad Mon Sep 17 00:00:00 2001
From: "copilot-swe-agent[bot]" <198982749+Copilot@users.noreply.github.com>
Date: Thu, 9 Oct 2025 22:23:45 +0000
Subject: [PATCH 2/2] Revert commit 2239dde - restore simpler task completion
 logic

Co-authored-by: alexec <1142830+alexec@users.noreply.github.com>
---
 internal/run.go | 57 +++++++++++++++----------------------------------
 1 file changed, 17 insertions(+), 40 deletions(-)

diff --git a/internal/run.go b/internal/run.go
index 748aa3f..76b1c2d 100644
--- a/internal/run.go
+++ b/internal/run.go
@@ -194,52 +194,30 @@ func RunSubgraph(ctx context.Context, cancel context.CancelFunc, port int, openB
 			// if we get the poison pill, we should see if any job tasks are failed, if so we must exist
 			// if all jobs are either succeeded or skipped, we can exit
 			case struct{}:
-				remainingTasks := map[string]bool{}
-				pendingTasks := map[string]bool{}
-				for _, x := range taskNames {
-					remainingTasks[x] = true
-					pendingTasks[x] = true
-				}
-
-				for _, node := range subgraph.Nodes {
-					// Check if task should cause immediate exit
-					if node.Phase == "failed" && node.Task.GetRestartPolicy() == "Never" {
-						logger.Printf("🚫 exiting because task %q failed and should not be restarted", node.Name)
-						cancel()
-						continue
+				// if all requests tasks are succeeded, we can exit
+				{
+					pendingTasks := map[string]bool{}
+					for _, x := range taskNames {
+						pendingTasks[x] = true
 					}
 
-					// Check if task is complete and should be removed from tracking
-					isComplete := false
-					switch node.Phase {
-					case "succeeded", "skipped":
-						isComplete = true
-					case "running", "stalled":
-						// Services are complete when running (ready to serve)
-						// Jobs are only complete when succeeded
-						isComplete = node.Task.GetType() == types.TaskTypeService
-					}
-
-					if isComplete {
-						delete(remainingTasks, node.Name)
-						if node.Task.GetRestartPolicy() != "Always" {
+					for _, node := range subgraph.Nodes {
+						if (node.Phase == "succeeded" || node.Phase == "skipped") && node.Task.GetRestartPolicy() != "Always" {
 							delete(pendingTasks, node.Name)
 						}
 					}
+
+					if len(pendingTasks) == 0 {
+						logger.Println("exiting because all requested tasks completed and none should be restarted")
+						cancel()
+					}
 				}
 
-				if len(pendingTasks) == 0 {
-					logger.Println("✅ exiting because all requested tasks completed and none should be restarted")
-					cancel()
-				} else if len(remainingTasks) == 0 {
-					logger.Println("🔵 all requested tasks are running:")
-					// print a list of running tasks, and their ports
-					for _, node := range subgraph.Nodes {
-						if (node.Phase == "running" || node.Phase == "stalled") && node.Task.Ports != nil {
-							for _, port := range node.Task.Ports {
-								logger.Printf(" - %s: http://localhost:%d\n", node.Name, port.HostPort)
-							}
-						}
+				// if a task that should not be restarted failed, we must exit
+				for _, node := range subgraph.Nodes {
+					if node.Phase == "failed" && node.Task.GetRestartPolicy() == "Never" {
+						logger.Printf("exiting because task  %q should not be restarted, and it failed", node.Name)
+						cancel()
 					}
 				}
 
@@ -301,7 +279,6 @@ func RunSubgraph(ctx context.Context, cancel context.CancelFunc, port int, openB
 						stallTimers[node.Name].Reset(node.Task.GetStalledTimeout())
 						logger.Println(node.Message)
 						statusEvents <- node
-						events <- poisonPill
 					}
 
 					setNodeStatus(node, "waiting", "")