Try fixing test

This commit is contained in:
Andras Schmelczer 2022-07-03 14:56:01 +02:00
parent d2c0acc900
commit ad1b2a20ef
3 changed files with 10 additions and 9 deletions

View file

@ -100,6 +100,7 @@ def parallel_map(
ctx.Process(
name=f"parallel_map_{config.function_name}_{i}",
target=mapper_function,
daemon=True,
kwargs=dict(
input_queue=input_queue,
output_queue=output_queue,