diff --git a/training/tf/chunkparser.py b/training/tf/chunkparser.py index 240875ef9..544559a87 100644 --- a/training/tf/chunkparser.py +++ b/training/tf/chunkparser.py @@ -119,7 +119,8 @@ def __init__(self, chunkdatasrc, shuffle_size=1, sample=1, buffer_size=1, batch_ for _ in range(workers): read, write = mp.Pipe(duplex=False) mp.Process(target=self.task, - args=(chunkdatasrc, write)).start() + args=(chunkdatasrc, write), + daemon=True).start() self.readers.append(read) write.close() self.init_structs()