From 60d2a2c7dffeb99bcf2d3a802c17559b81aaabe2 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Zolt=C3=A1n=20Papp?= Date: Wed, 19 Nov 2025 11:02:44 +0100 Subject: [PATCH] Fix error handling --- management/internals/shared/grpc/server.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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(),