diff --git a/management/internals/shared/grpc/server.go b/management/internals/shared/grpc/server.go
index 72c5ccbfd..647e24511 100644
--- a/management/internals/shared/grpc/server.go
+++ b/management/internals/shared/grpc/server.go
@@ -459,7 +459,7 @@ func (s *Server) sendJob(ctx context.Context, accountID string, peerKey wgtypes.
 	if err != nil {
 		log.WithContext(ctx).Errorf("failed to encrypt job for peer %s: %v", peerKey.String(), err)
 		s.jobManager.CloseChannel(ctx, accountID, peer.ID)
-		return nil
+		return status.Errorf(codes.Internal, "failed processing job message")
 	}
 	err = srv.Send(&proto.EncryptedMessage{
 		WgPubKey: s.wgKey.PublicKey().String(),