diff --git a/control-plane/pkg/reconciler/trigger/controller.go b/control-plane/pkg/reconciler/trigger/controller.go index a9783a25c2..2d03cd585e 100644 --- a/control-plane/pkg/reconciler/trigger/controller.go +++ b/control-plane/pkg/reconciler/trigger/controller.go @@ -125,7 +125,7 @@ func filterTriggers(lister eventinglisters.BrokerLister) func(interface{}) bool broker, err := lister.Brokers(trigger.Namespace).Get(trigger.Spec.Broker) if err != nil { - return true // TODO decide what to do on NotFound/Found + return false } value, ok := broker.GetAnnotations()[apiseventing.BrokerClassKey] diff --git a/control-plane/pkg/reconciler/trigger/controller_test.go b/control-plane/pkg/reconciler/trigger/controller_test.go index b67feef99f..4a4d2cbe53 100644 --- a/control-plane/pkg/reconciler/trigger/controller_test.go +++ b/control-plane/pkg/reconciler/trigger/controller_test.go @@ -54,5 +54,5 @@ func TestFilterTriggers(t *testing.T) { }, }) - assert.True(t, pass) + assert.False(t, pass) }