From 06a3df2d310f8d52bcb062c7d3e6a249723796d5 Mon Sep 17 00:00:00 2001 From: Krithika3 Date: Mon, 27 Jun 2022 12:37:55 -0700 Subject: [PATCH] feat: Added the right way to decipher from and to vertex (#78) Signed-off-by: Krithika Vijayakumar Co-authored-by: Krithika Vijayakumar Signed-off-by: Derek Wang --- pkg/daemon/server/service/isbs_query_service.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/pkg/daemon/server/service/isbs_query_service.go b/pkg/daemon/server/service/isbs_query_service.go index 59306a43b..70641df46 100644 --- a/pkg/daemon/server/service/isbs_query_service.go +++ b/pkg/daemon/server/service/isbs_query_service.go @@ -4,11 +4,12 @@ import ( "context" "fmt" + "k8s.io/utils/pointer" + "github.com/numaproj/numaflow/pkg/apis/numaflow/v1alpha1" "github.com/numaproj/numaflow/pkg/apis/proto/daemon" "github.com/numaproj/numaflow/pkg/isbsvc" "github.com/numaproj/numaflow/pkg/shared/logging" - "k8s.io/utils/pointer" ) type isbSvcQueryService struct { @@ -43,8 +44,8 @@ func (is *isbSvcQueryService) ListBuffers(ctx context.Context, req *daemon.ListB } b := &daemon.BufferInfo{ Pipeline: &is.pipeline.Name, - FromVertex: &edge.From, - ToVertex: &edge.To, + FromVertex: pointer.String(fmt.Sprintf("%v", edge.From)), + ToVertex: pointer.String(fmt.Sprintf("%v", edge.To)), BufferName: pointer.String(fmt.Sprintf("%v", buffer)), PendingCount: &bufferInfo.PendingCount, AckPendingCount: &bufferInfo.AckPendingCount,