fix: promote stale BLOCKED parent tasks to READY on server startup

When the server restarts after all subtasks complete, the parent task
was left stuck in BLOCKED state because maybeUnblockParent only fires
during a live executor run. RecoverStaleBlocked() scans all BLOCKED
tasks on startup and re-evaluates them using the existing logic.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

1 files changed, 59 insertions, 0 deletions

diff --git a/internal/executor/executor_test.go b/internal/executor/executor_test.go
index 610ed3b..878a32d 100644
--- a/internal/executor/executor_test.go
+++ b/internal/executor/executor_test.go
@@ -680,6 +680,65 @@ func TestPool_RecoverStaleQueued_SkipsNonQueuedTasks(t *testing.T) {
 	}
 }
 
+func TestPool_RecoverStaleBlocked_UnblocksWhenAllSubtasksCompleted(t *testing.T) {
+	store := testStore(t)
+	logger := slog.New(slog.NewTextHandler(os.Stderr, &slog.HandlerOptions{Level: slog.LevelError}))
+	pool := NewPool(2, map[string]Runner{"claude": &mockRunner{}}, store, logger)
+
+	// Parent task stuck in BLOCKED state (server restarted after subtasks completed).
+	parent := makeTask("parent-stale-blocked")
+	parent.State = task.StateBlocked
+	store.CreateTask(parent)
+
+	// All subtasks completed.
+	for i := 0; i < 3; i++ {
+		sub := makeTask(fmt.Sprintf("sub-%d", i))
+		sub.ParentTaskID = parent.ID
+		sub.State = task.StateCompleted
+		store.CreateTask(sub)
+	}
+
+	pool.RecoverStaleBlocked()
+
+	got, err := store.GetTask(parent.ID)
+	if err != nil {
+		t.Fatalf("get task: %v", err)
+	}
+	if got.State != task.StateReady {
+		t.Errorf("parent state: want READY, got %q", got.State)
+	}
+}
+
+func TestPool_RecoverStaleBlocked_KeepsBlockedWhenSubtaskIncomplete(t *testing.T) {
+	store := testStore(t)
+	logger := slog.New(slog.NewTextHandler(os.Stderr, &slog.HandlerOptions{Level: slog.LevelError}))
+	pool := NewPool(2, map[string]Runner{"claude": &mockRunner{}}, store, logger)
+
+	parent := makeTask("parent-still-blocked")
+	parent.State = task.StateBlocked
+	store.CreateTask(parent)
+
+	sub1 := makeTask("sub-done")
+	sub1.ParentTaskID = parent.ID
+	sub1.State = task.StateCompleted
+	store.CreateTask(sub1)
+
+	sub2 := makeTask("sub-running")
+	sub2.ParentTaskID = parent.ID
+	sub2.State = task.StateRunning
+	store.CreateTask(sub2)
+
+	pool.RecoverStaleBlocked()
+
+	got, err := store.GetTask(parent.ID)
+	if err != nil {
+		t.Fatalf("get task: %v", err)
+	}
+	if got.State != task.StateBlocked {
+		t.Errorf("parent state: want BLOCKED, got %q", got.State)
+	}
+}
+
 func TestPool_ActivePerAgent_DeletesZeroEntries(t *testing.T) {
 	store := testStore(t)
 	runner := &mockRunner{}