@@ -396,7 +396,7 @@ def download_project(self, project_path, directory, parallel=True):
396
396
for future in concurrent .futures .as_completed (futures_map ):
397
397
file = futures_map [future ]
398
398
try :
399
- future .result (60 )
399
+ future .result (600 )
400
400
except concurrent .futures .TimeoutError :
401
401
raise ClientError ("Timeout error: failed to download {}" .format (file ))
402
402
else :
@@ -454,7 +454,7 @@ def push_project(self, directory, parallel=True):
454
454
for future in concurrent .futures .as_completed (futures_map ):
455
455
file = futures_map [future ]
456
456
try :
457
- future .result (60 )
457
+ future .result (600 )
458
458
except concurrent .futures .TimeoutError :
459
459
raise ClientError ("Timeout error: failed to upload {}" .format (file ))
460
460
else :
@@ -521,13 +521,13 @@ def backup_if_conflict(path, checksum):
521
521
with concurrent .futures .ThreadPoolExecutor () as executor :
522
522
futures_map = {}
523
523
for file in fetch_files :
524
- future = executor .submit (project_path , server_info ['version' ], file , temp_dir , parallel )
524
+ future = executor .submit (self . _download_file , project_path , server_info ['version' ], file , temp_dir , parallel )
525
525
futures_map [future ] = file
526
526
527
527
for future in concurrent .futures .as_completed (futures_map ):
528
528
file = futures_map [future ]
529
529
try :
530
- future .result (60 )
530
+ future .result (600 )
531
531
except concurrent .futures .TimeoutError :
532
532
raise ClientError ("Timeout error: failed to download {}" .format (file ))
533
533
src = os .path .join (temp_dir , file ["path" ])
@@ -596,7 +596,7 @@ def download_file_part(part):
596
596
for future in concurrent .futures .as_completed (futures_map ):
597
597
i = futures_map [future ]
598
598
try :
599
- future .result (60 )
599
+ future .result (300 )
600
600
except concurrent .futures .TimeoutError :
601
601
raise ClientError ('Timeout error: failed to download part {} of file {}' .format (i , basename ))
602
602
else :
@@ -658,7 +658,7 @@ def upload_chunk(chunk_id, data):
658
658
for future in concurrent .futures .as_completed (futures_map ):
659
659
chunk = futures_map [future ]
660
660
try :
661
- future .result (60 )
661
+ future .result (300 )
662
662
except concurrent .futures .TimeoutError :
663
663
raise ClientError ('Timeout error: failed to upload chunk {}' .format (chunk ))
664
664
else :
0 commit comments