(self, db, batch_id, event_list)
Process all events in batch.
        
        By default calls process_event for each.
Process all events in batch.
        
        By default calls process_event for each.
Process all events in batch . By default calls process_event for each .
def process_batch(self, db, batch_id, event_list):
        """Process all events in batch.
        
        By default calls process_event for each.
        """
        dst_db = self.get_database(self.remote_db)
        curs = dst_db.cursor()

        if self.is_last_batch(curs, batch_id):
            return

        self.process_remote_batch(db, batch_id, event_list, dst_db)

        self.set_last_batch(curs, batch_id)
        dst_db.commit()
def process_batch ( self , db , batch_id , event_list ) : dst_db = self . get_database ( self . remote_db ) curs = dst_db . cursor ( ) if self . is_last_batch ( curs , batch_id ) : return self . process_remote_batch ( db , batch_id , event_list , dst_db ) self . set_last_batch ( curs , batch_id ) dst_db . commit ( )