upbound
diff --git a/‎fn.go‎
Lines changed: 11 additions & 7 deletions b/‎fn.go‎
Lines changed: 11 additions & 7 deletions
@@ -30,6 +30,13 @@ func (f *Function) RunFunction(_ context.Context, req *fnv1.RunFunctionRequest)
 	f.log.Info("Running function", "tag", req.GetMeta().GetTag())
 
 	rsp := response.To(req, response.DefaultTTL)
+	fctx := req.GetContext()
+	if len(fctx.AsMap()) == 0 {
+		// init map
+		fctx.Fields = make(map[string]*structpb.Value)
+	}
+	fctx.Fields["ops.upbound.io/ignored-resource"] = structpb.NewBoolValue(true)
+	rsp.Context = fctx
 
 	in := &v1alpha1.Input{}
 	if err := request.GetInput(req, in); err != nil {
@@ -80,13 +87,6 @@ func (f *Function) RunFunction(_ context.Context, req *fnv1.RunFunctionRequest)
 
 	if !match(in, e) {
 		f.log.Info("doesn't match", "event", fmt.Sprintf("%+v", e))
-		fctx := req.GetContext()
-		if len(fctx.AsMap()) == 0 {
-			// init map
-			fctx.Fields = make(map[string]*structpb.Value)
-		}
-		fctx.Fields["ops.upbound.io/ignored-resource"] = structpb.NewBoolValue(true)
-		rsp.Context = fctx
 
 		response.ConditionTrue(rsp, "FunctionSuccess", "Success").TargetCompositeAndClaim()
 		response.Normal(rsp, fmt.Sprintf("not interested in the given event %s, skipping", types.NamespacedName{Name: e.GetName(), Namespace: e.GetNamespace()}))
@@ -99,6 +99,10 @@ func (f *Function) RunFunction(_ context.Context, req *fnv1.RunFunctionRequest)
 	response.ConditionTrue(rsp, "FunctionSuccess", "Success").TargetCompositeAndClaim()
 	response.Normal(rsp, "passing along given event")
 	f.log.Info("matches", "event", fmt.Sprintf("%+v", e))
+
+	fctx.Fields["ops.upbound.io/ignored-resource"] = structpb.NewBoolValue(false)
+	rsp.Context = fctx
+
 	return rsp, nil
 }