def start(self):
self.observer = Observer()
self.observer.schedule(self, self.monitor_dir)
self.observer.start()
print("Starting to watch for new pdfs in %s" % (self.monitor_dir))
while True:
logging.info("Sleeping for %d seconds" % self.scan_interval)
time.sleep(self.scan_interval)
newFile = self.check_queue()
if newFile:
yield newFile
self.observer.join()
评论列表
文章目录