(self, dst_db)
On root node send seq changes to queue.
On root node send seq changes to queue.
On root node send seq changes to queue .
def process_root_node(self, dst_db):
        """On root node send seq changes to queue."""

        CascadedWorker.process_root_node(self, dst_db)

        q = "select * from londiste.root_check_seqs(%s)"
        self.exec_cmd(dst_db, q, [self.queue_name])
def process_root_node ( self , dst_db ) : CascadedWorker . process_root_node ( self , dst_db ) q = "select * from londiste.root_check_seqs(%s)" self . exec_cmd ( dst_db , q , [ self . queue_name ] )