(self, dst_curs, batch_id)
return dst_curs.fetchone()[0]
Helper function to keep track of last successful batch
        in external database.
Helper function to keep track of last successful batch
        in external database.
Helper function to keep track of last successful batch in external database .
def is_last_batch(self, dst_curs, batch_id):
        """Helper function to keep track of last successful batch
        in external database.
        """
        q = "select pgq_ext.is_batch_done(%s, %s)"
        dst_curs.execute(q, [ self.consumer_name, batch_id ])
        return dst_curs.fetchone()[0]
def is_last_batch ( self , dst_curs , batch_id ) : q = "select pgq_ext.is_batch_done(%s, %s)" dst_curs . execute ( q , [ self . consumer_name , batch_id ] ) return dst_curs . fetchone ( ) [ 0 ]