Use background context for background tasks

googleapis · Nov 27, 2020 · 8a2e7b9 · 8a2e7b9
1 parent c2dea0a
commit 8a2e7b9
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pubsublite/internal/wire/publisher.go b/pubsublite/internal/wire/publisher.go
@@ -385,7 +385,9 @@ func NewPublisher(ctx context.Context, settings PublishSettings, region, topicPa
 
 	msgRouterFactory := newMessageRouterFactory(rand.New(rand.NewSource(time.Now().UnixNano())))
 	pubFactory := &singlePartitionPublisherFactory{
-		ctx:       ctx,
+		// The user-provided context is used for background tasks (e.g. stream
+		// reconnects).
+		ctx:       context.Background(),
 		pubClient: pubClient,
 		settings:  settings,
 		topicPath: topicPath,