File tree Expand file tree Collapse file tree 1 file changed +7
-1
lines changed
internal/controller/syncmanager Expand file tree Collapse file tree 1 file changed +7
-1
lines changed Original file line number Diff line number Diff line change @@ -408,10 +408,16 @@ func getPublishedResourceKey(pr *syncagentv1alpha1.PublishedResource) string {
408408 return fmt .Sprintf ("%s-%s" , pr .UID , pr .ResourceVersion )
409409}
410410
411+ func isSyncEnabled (pr * syncagentv1alpha1.PublishedResource ) bool {
412+ return pr .Spec .Synchronization == nil || pr .Spec .Synchronization .Enabled
413+ }
414+
411415func (r * Reconciler ) ensureSyncControllers (ctx context.Context , log * zap.SugaredLogger , publishedResources []syncagentv1alpha1.PublishedResource ) error {
412416 requiredWorkers := sets .New [string ]()
413417 for _ , pr := range publishedResources {
414- requiredWorkers .Insert (getPublishedResourceKey (& pr ))
418+ if isSyncEnabled (& pr ) {
419+ requiredWorkers .Insert (getPublishedResourceKey (& pr ))
420+ }
415421 }
416422
417423 // stop controllers that are no longer needed
You can’t perform that action at this time.
0 commit comments