Skip to content

Commit f5f64ce

Browse files
dejanidejani
dejani
authored and
dejani
committed
Added pool.close() and pool.join() in upload method to fix resource leak
1 parent ba562a7 commit f5f64ce

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

src/oci/object_storage/transfer/internal/multipart_object_assembler.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -535,6 +535,8 @@ def upload(self, **kwargs):
535535
pool = Pool(processes=self.parallel_process_count)
536536
pool.map(lambda part_tuple: self._upload_part(part_num=part_tuple[0] + 1, part=part_tuple[1], **kwargs),
537537
enumerate(self.manifest["parts"]))
538+
pool.close()
539+
pool.join()
538540

539541
def upload_stream(self, stream_ref, **kwargs):
540542

0 commit comments

Comments
 (0)