'Reset the consume cycle.
Returns:
FairCycle: object that points to our _get_bulk() method
rather than the standard _get() method.  This allows for
multiple messages to be returned at once from SQS (
based on the prefetch limit).'

def _reset_cycle(self):

    self._cycle = scheduling.FairCycle(self._get_bulk, self._active_queues, Empty)
