Fix messages that are sent

rumpl · rumpl · commit b35072fd0e43 · 2025-09-25T19:57:37.000+02:00
On each loop iteration, we need to get the latest messages slice

Signed-off-by: Djordje Lukic &lt;djordje.lukic@docker.com&gt;
diff --git a/pkg/runtime/runtime.go b/pkg/runtime/runtime.go
@@ -228,6 +228,8 @@ func (r *runtime) RunStream(ctx context.Context, sess *session.Session) <-chan E
 				return
 			}
 			slog.Debug("Starting conversation loop iteration", "agent", a.Name())
+			// Looping, get the updated messages from the session
+			messages := sess.GetMessages(a)
 			slog.Debug("Retrieved messages for processing", "agent", a.Name(), "message_count", len(messages))
 
 			// Retry loop for getting agent tools with OAuth handling

Original file line number	Diff line number	Diff line change
`@@ -228,6 +228,8 @@ func (r runtime) RunStream(ctx context.Context, sess session.Session) <-chan E`
`228`	`228`	`return`
`229`	`229`	`}`
`230`	`230`	`slog.Debug("Starting conversation loop iteration", "agent", a.Name())`
	`231`	`+ // Looping, get the updated messages from the session`
	`232`	`+ messages := sess.GetMessages(a)`
`231`	`233`	`slog.Debug("Retrieved messages for processing", "agent", a.Name(), "message_count", len(messages))`
`232`	`234`
`233`	`235`	`// Retry loop for getting agent tools with OAuth handling`