diff --git a/pkg/agent/loop.go b/pkg/agent/loop.go index 27bafe977..01e7ce4c4 100644 --- a/pkg/agent/loop.go +++ b/pkg/agent/loop.go @@ -440,13 +440,6 @@ func (al *AgentLoop) publishResponseIfNeeded(ctx context.Context, channel, chatI }) } -func (al *AgentLoop) pendingSteeringCount() int { - if al.steering == nil { - return 0 - } - return al.steering.len() -} - func (al *AgentLoop) buildContinuationTarget(msg bus.InboundMessage) (*continuationTarget, error) { if msg.Channel == "system" { return nil, nil diff --git a/pkg/agent/steering_test.go b/pkg/agent/steering_test.go index 4c14dc6ef..cf2e86904 100644 --- a/pkg/agent/steering_test.go +++ b/pkg/agent/steering_test.go @@ -1036,7 +1036,7 @@ func TestAgentLoop_Continue_PreservesSteeringMedia(t *testing.T) { 0x00, 0x00, 0x00, 0x90, 0x77, 0x53, 0xDE, } - if err := os.WriteFile(pngPath, pngHeader, 0o644); err != nil { + if err = os.WriteFile(pngPath, pngHeader, 0o644); err != nil { t.Fatalf("WriteFile failed: %v", err) } ref, err := store.Store(pngPath, media.MediaMeta{Filename: "steer.png", ContentType: "image/png"}, "test") @@ -1060,7 +1060,7 @@ func TestAgentLoop_Continue_PreservesSteeringMedia(t *testing.T) { al := NewAgentLoop(cfg, msgBus, provider) al.SetMediaStore(store) - if err := al.Steer(providers.Message{ + if err = al.Steer(providers.Message{ Role: "user", Content: "describe this image", Media: []string{ref},