Method CleanupTask

service/admin/task.go:265–282

(c *gin.Context)

)

func (s *CleanupTaskService) CleanupTask(c *gin.Context) error {
	dep := dependency.FromContext(c)
	taskClient := dep.TaskClient()

	if len(s.Status) == 0 {
		s.Status = []task.Status{task.StatusCanceled, task.StatusCompleted, task.StatusError}
	}

	if err := taskClient.DeleteBy(c, &inventory.DeleteTaskArgs{
		NotAfter: s.NotAfter,
		Types:    s.Types,
		Status:   s.Status,
	}); err != nil {
		return serializer.NewError(serializer.CodeDBError, "Failed to cleanup tasks", err)
	}

	return nil
}