'Must override schedule method for scheduler to work.'

def schedule(self, context, topic, method, *_args, **_kwargs):

    raise NotImplementedError(_('Must    implement    a    fallback    schedule'))
