Don't leave threads running

This commit is contained in:
Andras Schmelczer 2022-07-02 00:13:25 +02:00
parent 9866b88faf
commit 2e12947429

View file

@ -81,6 +81,7 @@ def threaded_parallel_map(
threading.Thread(
name=f"threaded_parallel_map_{config.function_name}_{i}",
target=mapper_function,
daemon=True,
kwargs=dict(
input_queue=input_queue,
output_queue=output_queue,