(self)
return BaseConsumer.work(self)
Refresh state before calling Consumer.work().
Refresh state before calling Consumer.work().
Refresh state before calling Consumer . work () .
def work(self):
        """Refresh state before calling Consumer.work()."""

        dst_db = self.get_database(self.target_db)
        self._consumer_state = self.refresh_state(dst_db)

        if self._consumer_state['node_type'] == 'root':
            self.process_root_node(dst_db)
            return

        if not self.provider_connstr:
            raise Exception('provider_connstr not set')
        src_db = self.get_provider_db(self._consumer_state)

        return BaseConsumer.work(self)
def work ( self ) : dst_db = self . get_database ( self . target_db ) self . _consumer_state = self . refresh_state ( dst_db ) if self . _consumer_state [ 'node_type' ] == 'root' : self . process_root_node ( dst_db ) return if not self . provider_connstr : raise Exception ( 'provider_connstr not set' ) src_db = self . get_provider_db ( self . _consumer_state ) return BaseConsumer . work ( self )