From f5f64ce47232e732b7e169a4e55a83913269ce30 Mon Sep 17 00:00:00 2001 From: dejani Date: Wed, 3 Mar 2021 01:00:26 +0530 Subject: [PATCH] Added pool.close() and pool.join() in upload method to fix resource leak --- .../transfer/internal/multipart_object_assembler.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/oci/object_storage/transfer/internal/multipart_object_assembler.py b/src/oci/object_storage/transfer/internal/multipart_object_assembler.py index e60fa55250..8b345d38d0 100644 --- a/src/oci/object_storage/transfer/internal/multipart_object_assembler.py +++ b/src/oci/object_storage/transfer/internal/multipart_object_assembler.py @@ -535,6 +535,8 @@ def upload(self, **kwargs): pool = Pool(processes=self.parallel_process_count) pool.map(lambda part_tuple: self._upload_part(part_num=part_tuple[0] + 1, part=part_tuple[1], **kwargs), enumerate(self.manifest["parts"])) + pool.close() + pool.join() def upload_stream(self, stream_ref, **kwargs):