Skip to content

Commit 3d51cec

Browse files
committed
Close multiprocessing pool
1 parent 43dbc7f commit 3d51cec

File tree

2 files changed

+4
-8
lines changed

2 files changed

+4
-8
lines changed

wfdb/io/download.py

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -541,8 +541,6 @@ def dl_files(db, dl_dir, files, keep_subdirs=True, overwrite=False):
541541
print("Downloading files...")
542542
# Create multiple processes to download files.
543543
# Limit to 2 connections to avoid overloading the server
544-
pool = multiprocessing.dummy.Pool(processes=2)
545-
pool.map(dl_pn_file, dl_inputs)
544+
with multiprocessing.dummy.Pool(processes=2) as pool:
545+
pool.map(dl_pn_file, dl_inputs)
546546
print("Finished downloading files")
547-
548-
return

wfdb/io/record.py

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3117,8 +3117,6 @@ def dl_database(
31173117
print("Downloading files...")
31183118
# Create multiple processes to download files.
31193119
# Limit to 2 connections to avoid overloading the server
3120-
pool = multiprocessing.dummy.Pool(processes=2)
3121-
pool.map(download.dl_pn_file, dl_inputs)
3120+
with multiprocessing.dummy.Pool(processes=2) as pool:
3121+
pool.map(download.dl_pn_file, dl_inputs)
31223122
print("Finished downloading files")
3123-
3124-
return

0 commit comments

Comments
 (0)