replacement

type Dependencies struct {
	Repositories *repository.Repositories
	Messenger    *taskengine.Messenger
	RetryPolicy  TaskRetryPolicy
	Scheduler    *taskengine.Scheduler
}

type Handler struct {
	*taskengine.FuncHandler
	// contains filtered or unexported fields
}

type TaskRetryPolicy interface {
	RetryableContext(context.Context, *model.Task) (bool, error)
	InspectRetryWithRepositories(context.Context, *repository.Repositories, *model.Task) error
}