From 205adf8fa65b73e6b1070da59ed6345ed68f1ae1 Mon Sep 17 00:00:00 2001 From: Steve Nyemba Date: Thu, 26 Mar 2020 23:40:09 -0500 Subject: [PATCH] bug fix: epochs, process control (generator) --- pipeline.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/pipeline.py b/pipeline.py index 884609f..7620afd 100644 --- a/pipeline.py +++ b/pipeline.py @@ -327,6 +327,8 @@ if __name__ == '__main__' : job.name = 'generator # '+str(index) job.start() jobs.append(job) + if len(jobs) == 1 : + job.join() print (["Started ",len(jobs),"generators" if len(jobs)>1 else "generator" ]) while len(jobs)> 0 :