(self, curs, batch_id)
Fetch all events for this batch.
Fetch all events for this batch.
Fetch all events for this batch .
def _load_batch_events(self, curs, batch_id):
        """Fetch all events for this batch."""

        if self.pgq_lazy_fetch:
            return self._batch_walker_class(curs, batch_id, self.queue_name, self.pgq_lazy_fetch, self.consumer_filter)
        else:
            return self._load_batch_events_old(curs, batch_id)
def _load_batch_events ( self , curs , batch_id ) : if self . pgq_lazy_fetch : return self . _batch_walker_class ( curs , batch_id , self . queue_name , self . pgq_lazy_fetch , self . consumer_filter ) else : return self . _load_batch_events_old ( curs , batch_id )