From e570570fe502054e1c90957b821b4190d61f776a Mon Sep 17 00:00:00 2001 From: aliamerj Date: Fri, 10 Oct 2025 17:47:15 +0300 Subject: [PATCH] add some info level log --- client/internal/engine.go | 4 ++-- shared/management/client/grpc.go | 3 ++- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/client/internal/engine.go b/client/internal/engine.go index 714b0f100..ef026b322 100644 --- a/client/internal/engine.go +++ b/client/internal/engine.go @@ -992,9 +992,9 @@ func (e *Engine) receiveJobEvents() { e.clientCancel() return } - log.Debugf("stopped receiving jobs from Management Service") + log.Info("stopped receiving jobs from Management Service") }() - log.Debugf("connecting to Management Service jobs stream") + log.Info("connecting to Management Service jobs stream") } func (e *Engine) handleBundle(params *mgmProto.BundleParameters) (*mgmProto.JobResponse_Bundle, error) { diff --git a/shared/management/client/grpc.go b/shared/management/client/grpc.go index 87b8f3553..c7bab6766 100644 --- a/shared/management/client/grpc.go +++ b/shared/management/client/grpc.go @@ -201,6 +201,7 @@ func (c *GrpcClient) handleJobStream( continue } + log.WithContext(ctx).Infof("Received a new job from the management server (ID: %s)", jobReq.ID) jobResp := c.processJobRequest(ctx, jobReq, msgHandler) if err := c.sendJobResponse(ctx, stream, serverPubKey, jobResp); err != nil { return err @@ -283,7 +284,7 @@ func (c *GrpcClient) sendJobResponse( return err } - log.WithContext(ctx).Debugf("job response sent successfully for job %s", string(resp.ID)) + log.WithContext(ctx).Infof("Job %s completed successfully", resp.ID) return nil }