(self, db, batch_id, event_list)
Process all events in batch.
Process all events in batch.
Process all events in batch .
def process_batch(self, db, batch_id, event_list):
        """Process all events in batch.
        """

        dst_db = self.get_database(self.remote_db)
        curs = dst_db.cursor()

        # check if done
        if self.is_batch_done(curs):
            return

        # actual work
        self.process_remote_batch(db, batch_id, event_list, dst_db)

        # finish work
        self.set_batch_done(curs)
        dst_db.commit()
def process_batch ( self , db , batch_id , event_list ) : dst_db = self . get_database ( self . remote_db ) curs = dst_db . cursor ( ) # check if done if self . is_batch_done ( curs ) : return # actual work self . process_remote_batch ( db , batch_id , event_list , dst_db ) # finish work self . set_batch_done ( curs ) dst_db . commit ( )