utils.py 文件源码

def watch(self):
        # watch changes to the config file -- needs to be run in a separate thread
        configStatusManager = pyinotify.WatchManager()
        configStatusNotifier = pyinotify.Notifier(configStatusManager)
        configStatusManager.add_watch(self.path, pyinotify.IN_CLOSE_WRITE, proc_fun=PipelinesConfigUpdateHandler(config=self))
        configStatusNotifier.loop()