(self, dst_db, full_logic = True)
return res
Load also node state from target node.
Load also node state from target node.
Load also node state from target node .
def refresh_state(self, dst_db, full_logic = True):
        """Load also node state from target node.
        """
        res = CascadedConsumer.refresh_state(self, dst_db, full_logic)
        q = "select * from pgq_node.get_node_info(%s)"
        st = self.exec_cmd(dst_db, q, [ self.pgq_queue_name ])
        self._worker_state = WorkerState(self.pgq_queue_name, st[0])
        return res
def refresh_state ( self , dst_db , full_logic = True ) : res = CascadedConsumer . refresh_state ( self , dst_db , full_logic ) q = "select * from pgq_node.get_node_info(%s)" st = self . exec_cmd ( dst_db , q , [ self . pgq_queue_name ] ) self . _worker_state = WorkerState ( self . pgq_queue_name , st [ 0 ] ) return res