From cfe6edcfdade5a3804d17b84f3c3a78056344980 Mon Sep 17 00:00:00 2001 From: Yash Mehrotra Date: Thu, 20 Jul 2023 09:47:54 +0530 Subject: [PATCH] fix: respect agent_id and deleted_at for topologies --- pkg/db/topology.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/pkg/db/topology.go b/pkg/db/topology.go index f3a1d13bf..23189ae9e 100644 --- a/pkg/db/topology.go +++ b/pkg/db/topology.go @@ -63,7 +63,11 @@ func GetTopology(ctx context.Context, id string) (*v1.Topology, error) { func GetAllTopologiesForSync() ([]v1.Topology, error) { var v1topologies []v1.Topology var topologies []pkg.Topology - if err := Gorm.Table("topologies").Find(&topologies).Where("deleted_at is NULL AND namespace != 'push'").Error; err != nil { + if err := Gorm. + Table("topologies"). + Where("agent_id = '00000000-0000-0000-0000-000000000000'"). + Where("deleted_at is NULL"). + Find(&topologies).Error; err != nil { return nil, err } for _, t := range topologies {