Method deepCopy

pkg/task/task.go:70–100

()

}

func (t *BaseTask) deepCopy() *BaseTask {
	t.lock.RLock()
	defer t.lock.RUnlock()

	newTask := &BaseTask{
		Id:             t.Id,
		Type:           t.Type,
		FailureCount:   t.FailureCount,
		FailureMessage: t.FailureMessage,
		QueueName:      t.QueueName,
		QueuedAt:       t.QueuedAt,
		Metadata:       t.Metadata,
	}

	// Deep copy LogLabels
	newTask.LogLabels = make(map[string]string)
	for k, v := range t.LogLabels {
		newTask.LogLabels[k] = v
	}

	// Deep copy Props
	newTask.Props = make(map[string]interface{})
	for k, v := range t.Props {
		newTask.Props[k] = v
	}

	// Copy atomic bool value
	newTask.processing.Store(t.processing.Load())

	return newTask
}

func (t *BaseTask) DeepCopyWithNewUUID() Task {
	newTask := t.deepCopy()