Method delete

pkg/taskq/consumer.go:439–456

(ctx context.Context, job *Job)

}

func (c *Consumer) delete(ctx context.Context, job *Job) {
	if job.Err != nil {
		backend.Error(job.Err, "job failed (dropping)",
			"task_name", job.TaskName,
			"reserved_count", job.ReservedCount)

		if err := c.opt.Handler.HandleJob(ctx, job); err != nil {
			backend.Error(err, "fallback handler failed (dropping)",
				"task_name", job.TaskName)
		}
	}

	if err := c.q.Delete(ctx, job); err != nil {
		backend.Error(err, "Delete failed",
			"task_name", job.TaskName)
	}
	atomic.AddUint32(&c.inFlight, ^uint32(0))
}

// Purge discards messages from the internal queue.
func (c *Consumer) Purge(ctx context.Context) error {