(self, src_db, dst_db, tick_id)
Called after event processing.  This should finish
        work on remote db and commit there.
Called after event processing.  This should finish
        work on remote db and commit there.
Called after event processing . This should finish work on remote db and commit there .
def finish_remote_batch(self, src_db, dst_db, tick_id):
        """Called after event processing.  This should finish
        work on remote db and commit there.
        """
        # this also commits
        q = "select * from pgq_node.set_consumer_completed(%s, %s, %s)"
        self.exec_cmd(dst_db, q, [ self.queue_name, self.consumer_name, tick_id ])
def finish_remote_batch ( self , src_db , dst_db , tick_id ) : # this also commits q = "select * from pgq_node.set_consumer_completed(%s, %s, %s)" self . exec_cmd ( dst_db , q , [ self . queue_name , self . consumer_name , tick_id ] )