[release-12.0.1] Plugins: Fix issue with propagating ID token downstream for RunStream requests (#105002)

Plugins: Fix issue with propagating ID token downstream for RunStream requests (#104833) fix issue (cherry picked from commit a5649b6e1d)
2025-05-06 13:33:47 +01:00
parent 24bc8cc6bc
commit 5b795ae2e3
3 changed files with 115 additions and 3 deletions
@@ -244,6 +244,8 @@ func getDelay(numErrors int) time.Duration {

 // run stream until context canceled or stream finished without an error.
 func (s *Manager) runStream(ctx context.Context, cancelFn func(), sr streamRequest) {
+	ctx = identity.WithRequester(ctx, sr.user)
+
 	defer func() { s.stopStream(sr, cancelFn) }()
 	var numFastErrors int
 	var delay time.Duration