Function NewTaskFromModel

pkg/queue/task.go:129–135

NewTaskFromModel creates a Task from ent.Task model

(model *ent.Task)

// NewTaskFromModel creates a Task from ent.Task model
func NewTaskFromModel(model *ent.Task) (Task, error) {
	if factory, ok := taskFactories.Load(model.Type); ok {
		return factory.(ResumableTaskFactory)(model), nil
	}

	return nil, fmt.Errorf("unknown Task type: %s", model.Type)
}

// InMemoryTask implements part Task interface using in-memory data.
type InMemoryTask struct {