(self, dst_curs, batch_id)
Helper function to set last successful batch
        in external database.
Helper function to set last successful batch
        in external database.
Helper function to set last successful batch in external database .
def set_last_batch(self, dst_curs, batch_id):
        """Helper function to set last successful batch
        in external database.
        """
        q = "select pgq_ext.set_batch_done(%s, %s)"
        dst_curs.execute(q, [ self.consumer_name, batch_id ])
def set_last_batch ( self , dst_curs , batch_id ) : q = "select pgq_ext.set_batch_done(%s, %s)" dst_curs . execute ( q , [ self . consumer_name , batch_id ] )