Merge pull request #939 from sargun/fix-name

Fix key name in log entry
This commit is contained in:
Brian Goff
2021-01-08 10:43:50 -08:00
committed by GitHub

View File

@@ -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) {
}