in oss2/resumable.py [0:0]
def __is_record_sane(self, record):
try:
if record['op_type'] != self.__op:
logger.error('op_type invalid, op_type in record:{0} is invalid'.format(record['op_type']))
return False
for key in ('etag', 'tmp_suffix', 'file_path', 'bucket', 'key'):
if not isinstance(record[key], str):
logger.error('{0} is not a string: {1}'.format(key, record[key]))
return False
for key in ('part_size', 'size', 'mtime'):
if not isinstance(record[key], int):
logger.error('{0} is not an integer: {1}'.format(key, record[key]))
return False
if not isinstance(record['parts'], list):
logger.error('{0} is not a list: {1}'.format(key, record[key]))
return False
except KeyError as e:
logger.error('Key not found: {0}'.format(e.args))
return False
return True