(self, batch_info, dst_curs)
Called when batch finishes.
Called when batch finishes.
Called when batch finishes .
def finish_batch(self, batch_info, dst_curs):
        """Called when batch finishes."""
        if self.dst_queue_name is None: return

        fields = ['type', 'data',
                  'extra1', 'extra2', 'extra3', 'extra4', 'time']
        pgq.bulk_insert_events(dst_curs, self.rows, fields, self.dst_queue_name)
def finish_batch ( self , batch_info , dst_curs ) : if self . dst_queue_name is None : return fields = [ 'type' , 'data' , 'extra1' , 'extra2' , 'extra3' , 'extra4' , 'time' ] pgq . bulk_insert_events ( dst_curs , self . rows , fields , self . dst_queue_name )