(self, curs, batch_id, list)
Tag events and notify that the batch is done.
Tag events and notify that the batch is done.
Tag events and notify that the batch is done .
def _finish_batch(self, curs, batch_id, list):
        """Tag events and notify that the batch is done."""

        self._flush_retry(curs, batch_id, list)

        super(Consumer, self)._finish_batch(curs, batch_id, list)
def _finish_batch ( self , curs , batch_id , list ) : self . _flush_retry ( curs , batch_id , list ) super ( Consumer , self ) . _finish_batch ( curs , batch_id , list )