Function NewTimedTask

internal/job/timed_task.go:24–29

(l *zap.Logger, svc interfaces.RankingService)

}

func NewTimedTask(l *zap.Logger, svc interfaces.RankingService) *TimedTask {
	return &TimedTask{
		l:   l,
		svc: svc,
	}
}

func (t *TimedTask) ProcessTask(ctx context.Context, task *asynq.Task) error {
	var payload TimedPayload