def __setup(self):
global module_logger
filename = store_from_module(self.__calling_module)
#module_logger.info("Eventor store file: %s" % filename)
db_mode = DbMode.write if self.__run_mode==RunMode.restart else DbMode.append
#self.__db_daly_adj=0
#if self.__run_mode != RunMode.restart:
# try:
# db_mtime=os.path.getmtime(self.__filename)
# except OSError:
# pass
# else:
# self.__db_daly_adj=(datetime.now() - datetime.fromtimestamp(db_mtime)).total_seconds()
self.db = DbApi(config=self.__config, modulefile=filename, shared_db=self.shared_db, run_id=self.run_id, userstore=self.store, mode=db_mode, echo=False, logger=module_logger) #self.debug)
self.__requestors = vrp.Requestors()
if self.__run_mode == RunMode.restart:
self.__write_info()
else:
self.__read_info(run_mode=self.__run_mode, recovery_run=self.__recovery_run)
评论列表
文章目录