@@ -104,7 +104,7 @@ def upload_parts_sequential(file, presigned_urls, part_size, &block)
104104 end
105105 end
106106
107- def upload_parts_parallel ( file , presigned_urls , part_size , threads , &block )
107+ def upload_parts_parallel ( file , presigned_urls , part_size , threads , &)
108108 total_size = file . respond_to? ( :size ) ? file . size : ::File . size ( file . path )
109109 uploaded = { value : 0 }
110110 mutex = Mutex . new
@@ -131,26 +131,26 @@ def upload_parts_parallel(file, presigned_urls, part_size, threads, &block)
131131
132132 workers = threads . times . map do
133133 Thread . new do
134- run_parallel_worker ( worker_context , &block )
134+ run_parallel_worker ( worker_context , &)
135135 end
136136 end
137137
138138 workers . each ( &:join )
139139 raise errors . first if errors . any?
140140 end
141141
142- def run_parallel_worker ( context , &block )
142+ def run_parallel_worker ( context , &)
143143 ::File . open ( context [ :file_path ] , 'rb' ) do |worker_file |
144- process_parallel_jobs ( worker_file , context , &block )
144+ process_parallel_jobs ( worker_file , context , &)
145145 rescue StandardError => e
146146 record_parallel_error ( context , e )
147147 end
148148 end
149149
150- def process_parallel_jobs ( worker_file , context , &block )
150+ def process_parallel_jobs ( worker_file , context , &)
151151 loop do
152152 job = context [ :queue ] . pop
153- break unless process_parallel_job ( worker_file , context , job , &block )
153+ break unless process_parallel_job ( worker_file , context , job , &)
154154 end
155155 end
156156
0 commit comments