diff --git a/pkg/net/grpc/transport.go b/pkg/net/grpc/transport.go
index 943b61642..46c5c4993 100644
--- a/pkg/net/grpc/transport.go
+++ b/pkg/net/grpc/transport.go
@@ -135,7 +135,9 @@ func (tr *Transport) ApplyEvents(
 				}
 			}
 		case *eventpb.Event:
-			return tr.ApplyPbEvent(ctx, evt)
+			if err := tr.ApplyPbEvent(ctx, evt); err != nil {
+				return err
+			}
 		default:
 			return es.Errorf("GRPC transport only supports proto events and OutgoingMessage, received %T", event)
 		}