diff --git a/pkg/bus/bus.go b/pkg/bus/bus.go
index 9cd3f116172..9cf930aeb82 100644
--- a/pkg/bus/bus.go
+++ b/pkg/bus/bus.go
@@ -220,5 +220,5 @@ func ClearBusHandlers() {
 type noopTransactionManager struct{}
 
 func (*noopTransactionManager) InTransaction(ctx context.Context, fn func(ctx context.Context) error) error {
-	return nil
+	return fn(ctx)
 }