in FileReader.py [0:0]
def _fetchFileFromURI(self):
try:
handlers = { 's3:': self._fetchFromS3 }
src = self.fileURI.split("/")
protocol = src[0]
bucket = src[2]
key = "/".join(src[3:])
# check local cache before downloading
localFile = self._getLocalFilePath(key)
if Path(localFile).exists():
self._setLocalFile(localFile)
else:
handlers[protocol](bucket, key)
except Exception as err:
pass