@@ -374,10 +374,7 @@ func (a *agent) Run(ctx context.Context, sessionID string, content string, attac
374 a.activeRequests.Del(sessionID)
374 a.activeRequests.Del(sessionID)
376 a.Publish(pubsub.CreatedEvent, result)
376 a.Publish(pubsub.CreatedEvent, result)
378− case events <- result:
377+ events <- result
379− case <-genCtx.Done():
381 close(events)
378 close(events)
383 return events, nil
380 return events, nil