diff --git a/pkg/sync/syncer.go b/pkg/sync/syncer.go index 778e7f19d..52bf2ef9e 100644 --- a/pkg/sync/syncer.go +++ b/pkg/sync/syncer.go @@ -848,6 +848,11 @@ func (s *syncer) getSubResources(ctx context.Context, parent *v2.Resource) error ctx, span := tracer.Start(ctx, "syncer.getSubResources") defer span.End() + syncResourceTypeMap := make(map[string]bool) + for _, rt := range s.syncResourceTypes { + syncResourceTypeMap[rt] = true + } + for _, a := range parent.GetAnnotations() { if a.MessageIs((*v2.ChildResourceType)(nil)) { crt := &v2.ChildResourceType{} @@ -855,7 +860,11 @@ func (s *syncer) getSubResources(ctx context.Context, parent *v2.Resource) error if err != nil { return err } - + if len(s.syncResourceTypes) > 0 { + if shouldSync := syncResourceTypeMap[crt.GetResourceTypeId()]; !shouldSync { + continue + } + } childAction := Action{ Op: SyncResourcesOp, ResourceTypeID: crt.GetResourceTypeId(),