package scheduler

import (
	"context"

	"github.com/tidbcloud/pkgv2/log"
	"github.com/tidbcloud/pkgv2/logid"
	"go.uber.org/zap"
)

// clean task
func (s *Scheduler) Clean() {
	ctx := logid.WithLogid(context.Background(), logid.GenLogid())
	logger := log.WithContextL(ctx)

	logger.Info("start to run clean task")

	count, err := s.auditLogTaskRepo.Clean(ctx, nil)
	if err != nil {
		logger.Error("failed to clean audit log task", zap.Error(err))
		return
	}
	logger.Info("run clean task finish", zap.Int64("deleted_count", count))
}