in oss-torch-connector/osstorchconnector/oss_map_dataset.py [0:0]
def _get_transformed_object_safe(self, object: DataObject) -> Any:
eno = object.err()
if eno != 0:
errstr = "failed to get next object, errno=%d(%s), msg=%s" % (eno, os.strerror(eno), object.error_msg())
log.error("OssMapDataset get item %s faild: %s", object.key, errstr)
if eno == errno.ENOENT:
return self._transform(None)
else:
raise RuntimeError(errstr)
return self._transform(object)