From 3830b0ed79c2dad58570e4ef0d74c77b0ad4f831 Mon Sep 17 00:00:00 2001 From: Sargun Dhillon Date: Fri, 8 Jan 2021 01:00:22 -0800 Subject: [PATCH] Fix key name in log entry --- internal/queue/queue.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/queue/queue.go b/internal/queue/queue.go index 8f73477be..352c6600d 100644 --- a/internal/queue/queue.go +++ b/internal/queue/queue.go @@ -124,7 +124,7 @@ func (q *Queue) Run(ctx context.Context, workers int) { func (q *Queue) worker(ctx context.Context, i int) { ctx = log.WithLogger(ctx, log.G(ctx).WithFields(map[string]interface{}{ "workerId": i, - "Queue": q.name, + "queue": q.name, })) for q.handleQueueItem(ctx) { }