johno/gastown
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Fix swarm not tracking dynamically added workers (gt-qd9p0)

Browse Source 
Two bugs fixed in loadTasksFromBeads():
1. JSON field name mismatch: code parsed dependencies but bd show
   returns dependents - meant worker discovery always failed
2. Missing Assignee field: even if field name was correct, assignees
   were not being extracted from the bd show output

Also added hooked status to TaskInProgress mapping since workers
with hooked beads are actively working.

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
Steve Yegge
2025-12-29 21:56:29 -08:00
parent ba720fb82a
commit 10e797895a
1 changed files with 13 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
internal/swarm/manager.go
View File

@@ -225,15 +225,16 @@ func (m *Manager) loadTasksFromBeads(epicID string) ([]SwarmTask, error) {
// Parse JSON output - bd show returns an array
var issues []struct {
ID string `json:"id"`
Title string `json:"title"`
Status string `json:"status"`
Dependencies []struct {
ID string `json:"id"`
Title string `json:"title"`
Status string `json:"status"`
Dependents []struct {
ID string `json:"id"`
Title string `json:"title"`
Status string `json:"status"`
Assignee string `json:"assignee"`
DependencyType string `json:"dependency_type"`
} `json:"dependencies"`
} `json:"dependents"`
}
if err := json.Unmarshal(stdout.Bytes(), &issues); err != nil {
@@ -244,26 +245,27 @@ func (m *Manager) loadTasksFromBeads(epicID string) ([]SwarmTask, error) {
return nil, fmt.Errorf("epic not found: %s", epicID)
}
// Extract dependencies as tasks (issues that depend on/are blocked by this epic)
// Extract dependents as tasks (issues that depend on/are blocked by this epic)
// Accept both "parent-child" and "blocks" relationships
var tasks []SwarmTask
for _, dep := range issues[0].Dependencies {
for _, dep := range issues[0].Dependents {
if dep.DependencyType != "parent-child" && dep.DependencyType != "blocks" {
continue
}
state := TaskPending
switch dep.Status {
case "in_progress":
case "in_progress", "hooked":
state = TaskInProgress
case "closed":
state = TaskMerged
}
tasks = append(tasks, SwarmTask{
IssueID: dep.ID,
Title: dep.Title,
State: state,
IssueID: dep.ID,
Title: dep.Title,
State: state,
Assignee: dep.Assignee,
})
}