From 12602ad0c2124b6bf57c7ec8ca097b95612b3005 Mon Sep 17 00:00:00 2001 From: Todd Short Date: Tue, 4 Nov 2025 08:58:37 -0500 Subject: [PATCH] FOR TESTING ONLY Signed-off-by: Todd Short --- .../pkg/controller/registry/grpc/source.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/staging/operator-lifecycle-manager/pkg/controller/registry/grpc/source.go b/staging/operator-lifecycle-manager/pkg/controller/registry/grpc/source.go index c7aea05f44..5f2f587fa1 100644 --- a/staging/operator-lifecycle-manager/pkg/controller/registry/grpc/source.go +++ b/staging/operator-lifecycle-manager/pkg/controller/registry/grpc/source.go @@ -163,7 +163,9 @@ func grpcConnection(address string) (*grpc.ClientConn, error) { })) } - return grpc.NewClient(address, dialOptions...) + //REMOVED FOR TESTING + //return grpc.NewClient(address, dialOptions...) + return grpc.Dial(address, dialOptions...) } func (s *SourceStore) Add(key registry.CatalogKey, address string) (*SourceConn, error) { @@ -204,8 +206,9 @@ func (s *SourceStore) stateTimeout(state connectivity.State) time.Duration { func (s *SourceStore) watch(ctx context.Context, key registry.CatalogKey, source SourceConn) { state := source.ConnectionState + // REMOVED FOR TESTING // Make initial connection - source.Conn.Connect() + //source.Conn.Connect() // Periodically observe connection state change for {