diff --git a/fxgcppubsub/module.go b/fxgcppubsub/module.go index 1460d41..1cf0573 100644 --- a/fxgcppubsub/module.go +++ b/fxgcppubsub/module.go @@ -125,7 +125,7 @@ func NewFxGcpPubSubSchemaClient(p FxGcpPubSubSchemaClientParam) (*pubsub.SchemaC } } - client, err := pubsub.NewSchemaClient(p.Context, p.Config.GetString("modules.gcppubsub.project.id"), schemaClientOptions...) + client, err := pubsub.NewSchemaClient(context.Background(), p.Config.GetString("modules.gcppubsub.project.id"), schemaClientOptions...) if err != nil { return nil, fmt.Errorf("failed to create pubsub schema client: %w", err) }