fix(pubsub): tag ctx in iterator with subscription for opencensus (#5011

)
googleapis · Oct 25, 2021 · cdf9588 · cdf9588
1 parent 080edd1
commit cdf9588
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pubsub/iterator.go b/pubsub/iterator.go
@@ -92,6 +92,7 @@ func newMessageIterator(subc *vkit.SubscriberClient, subName string, po *pullOpt
 	nackTicker := time.NewTicker(100 * time.Millisecond)
 	pingTicker := time.NewTicker(30 * time.Second)
 	cctx, cancel := context.WithCancel(context.Background())
+	cctx = withSubscriptionKey(cctx, subName)
 	it := &messageIterator{
 		ctx:                cctx,
 		cancel:             cancel,