feat(fxgcppubsub): Added Avro and Protobuf schemas support

ankorstore · Jun 11, 2024 · 8868769 · 8868769
1 parent f9bc3bc
commit 8868769
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)
 	}