def _mark_watched(self, *args, **kwargs):
    raise NotImplementedError('This method must be implemented by subclasses')
def _mark_watched(self, *args, **kwargs):
    raise NotImplementedError('This method must be implemented by subclasses')