in dataflux_pytorch/dataflux_checkpoint.py [0:0]
def reader(self, object_name: str) -> BlobReader:
blob = self.bucket.blob(object_name)
stream = BytesIO()
blob.download_to_file(stream)
stream.seek(0)
return stream