def __init__(self, db_prefix, master_names):
self.db_prefix = db_prefix
# If this is None, then the last block will be used
# As master table
self.master_names = master_names
# different tables; one exec per table
self.data = {}
# master tables
self.master = {}
# list of exec names that are the last step in sequence
self.last_block = []
# key = block name, item = exec name
self.groups = {}
if os.path.isfile(self.db_prefix + '.map.mpk'):
self.maps = msgpack.unpackb(open(self.db_prefix + '.map.mpk', 'rb').read(), encoding = 'utf-8',
object_pairs_hook = OrderedDict)
else:
raise ResultDBError("DSC filename database is corrupted!")
评论列表
文章目录