Function persistTask

pkg/queue/task.go:476–487

(ctx context.Context, task Task, newState task.Status, q *queue)

}

func persistTask(ctx context.Context, task Task, newState task.Status, q *queue) error {
	// Persist Task into inventory
	if task.ShouldPersist() {
		if err := saveTaskToInventory(ctx, task, newState, q); err != nil {
			return err
		}
	} else {
		task.OnStatusTransition(newState)
	}

	return nil
}

func saveTaskToInventory(ctx context.Context, task Task, newStatus task.Status, q *queue) error {
	var (