Stone_Red/dvc
1
0
Fork 0
mirror of https://github.com/Stone-Red-Code/dvc.git synced 2026-11-04 15:28:27 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix deepsource issues

Browse Source
This commit is contained in:
Casper da Costa-Luis
2019-11-19 17:49:32 +00:00
parent b811a773c6
commit b2f7c841ef
1 changed files with 11 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
dvc/remote/gs.py
+11 -11
View File
@@ -63,8 +63,8 @@ def _upload_to_bucket(
bytes=True,
disable=no_progress_bar,
) as pbar:
with io.open(from_file, mode="rb") as fd:
raw_read = fd.read
with io.open(from_file, mode="rb") as fobj:
raw_read = fobj.read
def read(size=chunk_size):
res = raw_read(size)
@@ -72,8 +72,8 @@ def _upload_to_bucket(
pbar.update(len(res))
return res
fd.read = read
blob.upload_from_file(fd)
fobj.read = read
blob.upload_from_file(fobj)
class RemoteGS(RemoteBASE):
@@ -167,15 +167,15 @@ class RemoteGS(RemoteBASE):
bytes=True,
disable=no_progress_bar,
) as pbar:
with io.open(to_file, mode="wb") as fd:
raw_write = fd.write
with io.open(to_file, mode="wb") as fobj:
raw_write = fobj.write
def write(bytes):
raw_write(bytes)
pbar.update(len(bytes))
def write(byte_string):
raw_write(byte_string)
pbar.update(len(byte_string))
fd.write = write
blob.download_to_file(fd)
fobj.write = write
blob.download_to_file(fobj)
def _generate_download_url(self, path_info, expires=3600):
expiration = timedelta(seconds=int(expires))