Adding owner for cronjob watch

kubeflow · May 31, 2019 · df9f22c · df9f22c
1 parent 4e342cc
commit df9f22c
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/pkg/controller/v1alpha2/trial/trial_controller.go b/pkg/controller/v1alpha2/trial/trial_controller.go
@@ -87,7 +87,13 @@ func add(mgr manager.Manager, r reconcile.Reconciler) error {
 	}
 
 	// Watch for changes to Cronjob
-	err = c.Watch(&source.Kind{Type: &batchv1beta.CronJob{}}, &handler.EnqueueRequestForObject{})
+	err = c.Watch(
+		&source.Kind{Type: &batchv1beta.CronJob{}},
+		&handler.EnqueueRequestForOwner{
+			IsController: true,
+			OwnerType:    &trialsv1alpha2.Trial{},
+		})
+
 	if err != nil {
 		log.Error(err, "CronJob watch error")
 		return err