Method newContext

pkg/queue/queue.go:212–219

newContext creates a new context for a new Task iteration.

(t Task)

// newContext creates a new context for a new Task iteration.
func (q *queue) newContext(t Task) context.Context {
	l := q.logger.CopyWithPrefix(fmt.Sprintf("[Cid: %s TaskID: %d Queue: %s]", t.CorrelationID(), t.ID(), q.name))
	ctx := q.dep.ForkWithLogger(q.rootCtx, l)
	ctx = context.WithValue(ctx, logging.CorrelationIDCtx{}, t.CorrelationID())
	ctx = context.WithValue(ctx, logging.LoggerCtx{}, l)
	ctx = context.WithValue(ctx, inventory.UserCtx{}, t.Owner())
	return ctx
}

func (q *queue) work(t Task) {
	ctx := q.newContext(t)