summaryrefslogtreecommitdiff
path: root/internal/executor/helpers.go
diff options
context:
space:
mode:
authorPeter Stone <thepeterstone@gmail.com>2026-03-18 07:54:27 +0000
committerPeter Stone <thepeterstone@gmail.com>2026-03-18 07:55:27 +0000
commita4795d68fc5381f1ff48d043fe7554355e5899fb (patch)
tree26dc8ea78c3896021f53f3d1bb6731c197a6cfeb /internal/executor/helpers.go
parente1be377c851f1e7ce594fa3de6c429354bcedcce (diff)
fix: address final container execution issues and cleanup review docs
Diffstat (limited to 'internal/executor/helpers.go')
-rw-r--r--internal/executor/helpers.go4
1 files changed, 3 insertions, 1 deletions
diff --git a/internal/executor/helpers.go b/internal/executor/helpers.go
index 36cd050..9e4530b 100644
--- a/internal/executor/helpers.go
+++ b/internal/executor/helpers.go
@@ -33,6 +33,7 @@ func parseStream(r io.Reader, w io.Writer, logger *slog.Logger) (float64, string
var sessionID string
var streamErr error
+Loop:
for scanner.Scan() {
line := scanner.Bytes()
var msg map[string]interface{}
@@ -54,7 +55,7 @@ func parseStream(r io.Reader, w io.Writer, logger *slog.Logger) (float64, string
if status == "rejected" {
streamErr = fmt.Errorf("claude rate limit reached (rejected): %v", msg)
// Immediately break since we can't continue anyway
- break
+ break Loop
}
}
case "assistant":
@@ -91,6 +92,7 @@ func parseStream(r io.Reader, w io.Writer, logger *slog.Logger) (float64, string
return totalCost, sessionID, streamErr
}
+
// permissionDenialError inspects a "user" stream message for tool_result entries
// that were denied due to missing permissions. Returns an error if found.
func permissionDenialError(msg map[string]interface{}) error {