summaryrefslogtreecommitdiff
path: root/internal/executor/executor.go
diff options
context:
space:
mode:
authorClaudomator Agent <agent@claudomator>2026-04-11 18:10:32 +0000
committerClaudomator Agent <agent@claudomator>2026-04-11 18:10:32 +0000
commite94573bb84874eda7d233cafc36f3a21688c0568 (patch)
tree31a3bce72364b08829502b3d3ffa1abbc0962f3d /internal/executor/executor.go
parent40513ffddba01467193c3c3e19468c7090f06215 (diff)
cleanup: remove dead code (QuestionRegistry, changestats wrappers, scanner.Err)
Fix 1: Remove QuestionRegistry and related types (QuestionHandler, PendingQuestion) from question.go -- nothing reads Pool.Questions or uses the registry. Remove NewQuestionRegistry() call from NewPool and the Questions field from Pool. Remove the now-superfluous registry tests; keep stream/parse helpers which are still used by the claude runner. Fix 2: Check scanner.Err() after the parseStream loop so I/O errors from the scanner are not silently swallowed when streamErr is still nil. Fix 3: Delete internal/api/changestats.go -- the parseChangestatFromFile and parseChangestatFromOutput wrappers were only needed to support processResult(), which no longer calls them; they are unreachable dead code. Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
Diffstat (limited to 'internal/executor/executor.go')
-rw-r--r--internal/executor/executor.go2
1 files changed, 0 insertions, 2 deletions
diff --git a/internal/executor/executor.go b/internal/executor/executor.go
index ac528c6..8257f31 100644
--- a/internal/executor/executor.go
+++ b/internal/executor/executor.go
@@ -84,7 +84,6 @@ type Pool struct {
doneCh chan struct{} // signals when a worker slot is freed
workerWg sync.WaitGroup // tracks in-flight execute/executeResume goroutines
dispatchDone chan struct{} // closed when the dispatch goroutine exits
- Questions *QuestionRegistry
Classifier *Classifier
}
@@ -116,7 +115,6 @@ func NewPool(maxConcurrent int, runners map[string]Runner, store Store, logger *
workCh: make(chan workItem, maxConcurrent*10+100),
doneCh: make(chan struct{}, maxConcurrent),
dispatchDone: make(chan struct{}),
- Questions: NewQuestionRegistry(),
}
go p.dispatch()
return p