(self)
Main entry point for running pillows forever.
Main entry point for running pillows forever.
Main entry point for running pillows forever .
def run(self):
        """
        Main entry point for running pillows forever.
        """
        pillow_logging.info("Starting pillow %s" % self.__class__)
        with configure_scope() as scope:
            scope.set_tag("pillow_name", self.get_name())
        if self.is_dedicated_migration_process:
            for processor in self.processors:
                processor.bootstrap_if_needed()
            time.sleep(10)
        else:
            while True:
                self.process_changes(since=self.get_last_checkpoint_sequence(), forever=True)
def run ( self ) : pillow_logging . info ( "Starting pillow %s" % self . __class__ ) with configure_scope ( ) as scope : scope . set_tag ( "pillow_name" , self . get_name ( ) ) if self . is_dedicated_migration_process : for processor in self . processors : processor . bootstrap_if_needed ( ) time . sleep ( 10 ) else : while True : self . process_changes ( since = self . get_last_checkpoint_sequence ( ) , forever = True )