@@ -453,8 +453,8 @@ def __init__(
453453
454454 def dump (self ):
455455 print ("--- JOB ---" , self .total_size , "bytes" )
456- for file_to_merge in self .files_to_merge :
457- print ("- {} ... download items={}" .format (file_to_merge .dest_file , len (file_to_merge .downloaded_items )))
456+ for download_file in self .download_files :
457+ print ("- {} ... download items={}" .format (download_file .dest_file , len (download_file .downloaded_items )))
458458 print ("--" )
459459 for basefile , diffs in self .basefiles_to_patch :
460460 print ("patch basefile {} with {} diffs" .format (basefile , len (diffs )))
@@ -813,7 +813,7 @@ def download_diffs_async(mc, project_directory, file_path, versions):
813813 diff_data ["diff" ] = version_data ["diff" ]
814814 fetch_files .append (diff_data )
815815
816- files_to_merge = [] # list of FileToMerge instances
816+ download_files = [] # list of DownloadFile instances
817817 download_list = [] # list of all items to be downloaded
818818 total_size = 0
819819 for file in fetch_files :
@@ -829,7 +829,7 @@ def download_diffs_async(mc, project_directory, file_path, versions):
829829 dest_file_path = mp .fpath_cache (diff ["path" ], version = file ["version" ])
830830 if os .path .exists (dest_file_path ):
831831 continue
832- files_to_merge .append (DownloadFile (dest_file_path , items ))
832+ download_files .append (DownloadFile (dest_file_path , items ))
833833 download_list .extend (items )
834834 for item in items :
835835 total_size += item .size
@@ -841,7 +841,7 @@ def download_diffs_async(mc, project_directory, file_path, versions):
841841 None ,
842842 total_size ,
843843 None ,
844- files_to_merge ,
844+ download_files ,
845845 download_list ,
846846 mp .cache_dir ,
847847 mp ,
@@ -860,7 +860,7 @@ def download_diffs_async(mc, project_directory, file_path, versions):
860860 return job
861861
862862
863- def download_diffs_finalize (job ) :
863+ def download_diffs_finalize (job : PullJob ) -> List [ str ] :
864864 """To be called after download_diffs_async
865865
866866 Returns:
@@ -881,9 +881,9 @@ def download_diffs_finalize(job):
881881
882882 # merge downloaded chunks
883883 try :
884- for file_to_merge in job .files_to_merge :
885- file_to_merge . merge ()
886- diffs .append (file_to_merge .dest_file )
884+ for download_file in job .download_files :
885+ download_file . from_chunks ()
886+ diffs .append (download_file .dest_file )
887887 except ClientError as err :
888888 job .mp .log .error ("Error merging chunks of downloaded file: " + str (err ))
889889 job .mp .log .info ("--- diffs pull aborted" )
0 commit comments