@@ -108,7 +108,11 @@ def gdrive_download_file(
108
108
from dvc .progress import Tqdm
109
109
110
110
gdrive_file = self .drive .CreateFile ({"id" : file_id })
111
- with Tqdm (desc = progress_name , total = int (gdrive_file ["fileSize" ]), disable = no_progress_bar ):
111
+ with Tqdm (
112
+ desc = progress_name ,
113
+ total = int (gdrive_file ["fileSize" ]),
114
+ disable = no_progress_bar ,
115
+ ):
112
116
gdrive_file .GetContentFile (to_file )
113
117
114
118
def gdrive_list_item (self , query ):
@@ -132,20 +136,20 @@ def cache_root_dirs(self):
132
136
133
137
@property
134
138
def cached_dirs (self ):
135
- if not hasattr (self , ' _cached_dirs' ):
139
+ if not hasattr (self , " _cached_dirs" ):
136
140
self .drive
137
141
return self ._cached_dirs
138
142
139
143
@property
140
144
def cached_ids (self ):
141
- if not hasattr (self , ' _cached_ids' ):
145
+ if not hasattr (self , " _cached_ids" ):
142
146
self .drive
143
147
return self ._cached_ids
144
148
145
149
@property
146
150
@wrap_with (threading .RLock ())
147
151
def drive (self ):
148
- if not hasattr (self , ' _gdrive' ):
152
+ if not hasattr (self , " _gdrive" ):
149
153
from pydrive .auth import GoogleAuth
150
154
from pydrive .drive import GoogleDrive
151
155
@@ -214,7 +218,9 @@ def get_remote_item(self, name, parents_ids):
214
218
query += " and trashed=false and title='{}'" .format (name )
215
219
216
220
# Limit found remote items count to 1 in response
217
- item_list = self .drive .ListFile ({"q" : query , "maxResults" : 1 }).GetList ()
221
+ item_list = self .drive .ListFile (
222
+ {"q" : query , "maxResults" : 1 }
223
+ ).GetList ()
218
224
return next (iter (item_list ), None )
219
225
220
226
def resolve_remote_item_from_path (self , parents_ids , path_parts , create ):
@@ -240,7 +246,9 @@ def subtract_root_path(self, path_parts):
240
246
241
247
def get_remote_id_from_cache (self , path_info ):
242
248
remote_ids = []
243
- path_parts , parents_ids = self .subtract_root_path (path_info .path .split ("/" ))
249
+ path_parts , parents_ids = self .subtract_root_path (
250
+ path_info .path .split ("/" )
251
+ )
244
252
if (
245
253
hasattr (self , "_cached_dirs" )
246
254
and path_info != self .path_info
@@ -254,12 +262,16 @@ def get_remote_id_from_cache(self, path_info):
254
262
return remote_ids , parents_ids , path_parts
255
263
256
264
def get_remote_id (self , path_info , create = False ):
257
- remote_ids , parents_ids , path_parts = self .get_remote_id_from_cache (path_info )
265
+ remote_ids , parents_ids , path_parts = self .get_remote_id_from_cache (
266
+ path_info
267
+ )
258
268
259
269
if not path_parts and remote_ids :
260
270
return remote_ids [0 ]
261
271
262
- file1 = self .resolve_remote_item_from_path (parents_ids , path_parts , create )
272
+ file1 = self .resolve_remote_item_from_path (
273
+ parents_ids , path_parts , create
274
+ )
263
275
return file1 ["id" ] if file1 else ""
264
276
265
277
def exists (self , path_info ):
0 commit comments