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 }