Merge branch 'vsukhin/feature/stream-service-logs' into sandbox/twrc

kubeshop · Dec 9, 2024 · a5812ac · a5812ac
2 parents 71095a1 + e899798
commit a5812ac
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/agent/testworkflows.go b/pkg/agent/testworkflows.go
@@ -42,6 +42,8 @@ func getTestWorkflowNotificationType(n testkube.TestWorkflowExecutionNotificatio
 
 func (ag *Agent) runTestWorkflowNotificationsLoop(ctx context.Context) error {
 	ctx = agentclient.AddAPIKeyMeta(ctx, ag.apiKey)
+	ctx = metadata.AppendToOutgoingContext(ctx, envIdMeta, ag.proContext.EnvID)
+	ctx = metadata.AppendToOutgoingContext(ctx, orgIdMeta, ag.proContext.OrgID)
 
 	ag.logger.Infow("initiating workflow notifications streaming connection with Cloud API")
 	// creates a new Stream from the client side. ctx is used for the lifetime of the stream.