From 9f6f4cbd895edfd78cea341394658ed9d498f016 Mon Sep 17 00:00:00 2001 From: artaasadi Date: Tue, 12 Nov 2024 17:16:39 +0100 Subject: [PATCH] fix: compliance worker logs --- pkg/compliance/runner/job.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/pkg/compliance/runner/job.go b/pkg/compliance/runner/job.go index 626665837..2b577e7ce 100644 --- a/pkg/compliance/runner/job.go +++ b/pkg/compliance/runner/job.go @@ -146,6 +146,9 @@ func (w *Worker) RunJob(ctx context.Context, j Job) (int, error) { zap.Uint("job_id", j.ID), zap.Int("res_count", len(res.Data)), zap.Int("caller_count", len(j.ExecutionPlan.Callers)), + zap.Any("res", *res), + zap.String("query", j.ExecutionPlan.Query.QueryToExecute), + zap.String("query_id", j.ExecutionPlan.Query.ID), ) totalComplianceResultCountMap := make(map[string]int)