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

        # load events
        sql = "select * from pgq.get_batch_events(%d)" % batch_id
        if self.consumer_filter is not None:
            sql += " where %s" % self.consumer_filter
        curs.execute(sql)
        rows = curs.fetchall()

        # map them to python objects
        ev_list = []
        for r in rows:
            ev = self._make_event(self.queue_name, r)
            ev_list.append(ev)

        return ev_list
def _load_batch_events_old ( self , curs , batch_id ) : # load events sql = "select * from pgq.get_batch_events(%d)" % batch_id if self . consumer_filter is not None : sql += " where %s" % self . consumer_filter curs . execute ( sql ) rows = curs . fetchall ( ) # map them to python objects ev_list = [ ] for r in rows : ev = self . _make_event ( self . queue_name , r ) ev_list . append ( ev ) return ev_list